【文件属性】：
文件名称：kafka-nodejs:NodeJS 和 Kafka 使用 kafka-node
文件大小：12KB
文件格式：ZIP
更新时间：2021-06-10 14:33:27
JavaScript
#集成NODEJS和Kafka
＃＃＃目录
步骤 1 - 将以下脚本复制到名为producer_nodejs.js的文件中。
第 2 步 - 启动kafka集群，就像我们在Installation of Kafka所做的那样。 假设主题为test
第 3 步 - 按照以下命令启动消费者服务。
第 4 步 - 执行以下命令。 这将发送This is the First Message I am sending Kafka 消费者This is the First Message I am sending消息This is the First Message I am sending 。
第 5 步 - 检查消费者，您将看到从nodejs发送的消息。
将 JSON 发送到 NodeJS 到 Kafka。
步骤 1 - 使用以下脚本创建一个名为json_nodejs_kafka.
【文件预览】：
kafka-nodejs-master
----send_data_to_kafka.js(1KB)
----json_nodejs_kafka.js(2KB)
----json_recv_nodejs.js(817B)
----LICENSE(1KB)
----README.md(18KB)
----send_json_multiple_topics()
--------README.md(5KB)
--------json_nodejs_multiple_topics.js(8KB)