要使用Apache Kafka 2.3和Node.js 10.15编写消费者和生产者代码示例,您需要按照以下步骤进行设置:
安装Apache Kafka 2.3:您可以从官方网站下载并安装Apache Kafka 2.3。根据您的操作系统,选择适当的下载版本并按照安装说明进行设置。
安装Node.js 10.15:您可以从Node.js官方网站下载并安装Node.js 10.15。根据您的操作系统,选择适当的下载版本并按照安装说明进行设置。
创建一个Kafka主题:在使用Kafka之前,您需要创建一个主题。您可以使用Kafka提供的命令行工具或通过编程方式创建主题。
安装Kafka Node.js包:在Node.js中使用Kafka,您需要安装一个Kafka Node.js客户端包。您可以使用npm命令安装kafka-node包,如下所示:
npm install kafka-node
const kafka = require('kafka-node');
const Consumer = kafka.Consumer;
const client = new kafka.KafkaClient({ kafkaHost: 'localhost:9092' });
const consumer = new Consumer(
client,
[{ topic: 'your-topic-name' }],
{ autoCommit: true }
);
consumer.on('message', function (message) {
console.log('Received message:', message.value);
});
consumer.on('error', function (error) {
console.log('Error:', error);
});
请将your-topic-name
替换为您创建的Kafka主题名称。
const kafka = require('kafka-node');
const Producer = kafka.Producer;
const client = new kafka.KafkaClient({ kafkaHost: 'localhost:9092' });
const producer = new Producer(client);
producer.on('ready', function () {
const message = 'Hello Kafka!';
const payloads = [
{
topic: 'your-topic-name',
messages: message
}
];
producer.send(payloads, function (error, data) {
if (error) {
console.log('Error:', error);
} else {
console.log('Message sent:', data);
}
});
});
producer.on('error', function (error) {
console.log('Error:', error);
});
请将your-topic-name
替换为您创建的Kafka主题名称。
node consumer.js
node producer.js
这将启动消费者和生产者,并将它们连接到本地Kafka代理。消费者将等待从主题接收消息,并在接收到消息时打印消息内容。生产者将发送包含“Hello Kafka!”消息的数据到指定的主题。
请注意,您需要根据您的Kafka配置和需求进行适当的更改和调整代码示例。这些示例只是演示如何使用Apache Kafka 2.3和Node.js 10.15编写消费者和生产者代码。