kafka-nodejs:NodeJS 和 Kafka 使用 kafka-node

时间:2024-06-30 08:20:07
【文件属性】:

文件名称:kafka-nodejs:NodeJS 和 Kafka 使用 kafka-node

文件大小:12KB

文件格式:ZIP

更新时间:2024-06-30 08:20:07

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)

网友评论