我为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
我正在使用命令提示符,目前没有客户端进行测试 .
谢谢,