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


Logo

CSDN联合极客时间,共同打造面向开发者的精品内容学习社区,助力成长!

更多推荐