小编use*_*640的帖子

我是卡夫卡的新人.当我在命令行中运行快速启动示例时,我发现无法在命令行中创建多个使用者.

条件:

我用3个分区构建了一个名为test的主题,我还在这个主题上构建了一个生产者.

然后我想创建两个不同的消费者,在这个主题上共享一个名为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)