bin/kafka-console-consumer.sh –bootstrap-server xxx05:9092 –topic xxx_mongo.xxx2021 –from-beginning
bin/kafka-console-consumer.sh –bootstrap-server xxx05:9092 –topic xxx_mongo.xxx
bin/kafka-console-consumer.sh –bootstrap-server xxx:9092 –topic xxx_xxx
– 指定消费者组消费
bin/kafka-console-consumer.sh –bootstrap-server xxx:9092 –topic xxx_xxx –consumer-property group.id=group_mytest

– 获取 kafka 消息 key

bin/kafka-console-consumer.sh –bootstrap-server –bootstrap-server xxx:9092 –property print.key=true –topic xxx_xxx

文档更新时间: 2023-07-18 10:51   作者:月影鹏鹏
IT运维支持-AIWALY-月影工作室