kafka设置消费者组

安装部署后

consumer.properties

group.id=test-group

单机测试，自己开俩窗口，一个测试消费者，一个测试生产者（创建消息那步）

创建主题
bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic mytesttopic
查看主题
bin/kafka-topics.sh --list --bootstrap-server localhost:9092 hd-topic
删除消费者
bin/kafka-topics.sh --bootstrap-server localhost:9092 --topic mytopic --delete?
查看消费者组
bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list
创建消息
kafka-console-producer.sh --bootstrap-server localhost:9092 --topic mytesttopic

>? 11111111

出现上边的大于号，就可以输入消息了。

再开启个窗口，消费者角度查看消息

kafka-console-consumer.sh --bootstrap-server localhost:9092 ?--topic mytesttopic --group test-group --from-beginning

--from-beginning是从头消费，不带他是之前的不消费，生产者再创建时消费最新的

刚开始研究，还不是太明白。只研究了这些基本步骤。