Kafka-NodeJS-Client-Test:Kafka NodeJS客户端测试

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的组中的本地主机