文件名称:Kafka-NodeJS-Client-Test:Kafka NodeJS客户端测试
文件大小:4KB
文件格式:ZIP
更新时间:2024-05-20 13:04:48
JavaScript
Kafka NodeJS客户端测试 简而言之,所有需要的代码都能正常工作是一个简单的起点。 它使用来自的库以及它们提供的示例的混合。 该代码仅用于测试目的。 Kafka安装使用以下教程进行: : 创建主题 ./kafka/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 2 --topic KAFKAJSTests 消费 以这种方式解雇使用者(至多为您拥有的分区数): KAFKACLUSTER=localhost node consumer.js [topic] [groupId] [partition] 所有参数都有默认值,因此您可以简单地运行: node consumer.js 它将连接到名为kafka-node-group的组中的本地主机
【文件预览】:
Kafka-NodeJS-Client-Test-master
----producer.js(2KB)
----package.json(288B)
----LICENSE(1KB)
----.gitignore(526B)
----consumer.js(1KB)
----README.md(1KB)