我是卡夫卡的新手。当我在命令行中运行快速启动示例时，我发现无法在命令行中创建多个使用者。
健康）状况：
我构建了一个名为 test 的主题，包含 3 个分区，并且还针对该主题构建了一个生产者。
然后我想创建两个不同的消费者，共享关于此主题的名为 test1 的同一消费者组。
我运行了如下命令两次：
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --group test1
第一个有效，但当我第二次运行时，第一个会断开连接，第二个有效。
那么如何在命令行中的同一个消费者组中创建两个或多个消费者呢？
WARN Session 0x0 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn)
java.net.ConnectException: Connection refused
at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:739)
at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1146)
除了使用--consumer.config像 secfree 的答案一样的选项，您也可以使用
--consumer-property group.id=your_group
无需编辑配置文件即可指定组名称的选项。
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
