我为kafka设置了单机,想要运行基于que的kaffa . 我在consumer.properties中设置了这样的组名 .

消费者群组ID

group.id =测试消费者组

当我为同一主题运行2个消费者时,都获得了消息 . 除此之外还有什么我需要做的吗?

sudo bin / kafka-console-consumer.sh config / consumer.properties --zookeeper localhost:2181 --topic 219Topic --from-beginning

我正在使用命令提示符,目前没有客户端进行测试 .

谢谢,