Kafka常用命令之kafka-console-consumer.sh
kafka-console-consumer.sh 脚本是一个简易的消费者控制台。该 shell 脚本的功能通过调用 kafka.tools 包下的 ConsoleConsumer 类,并将提供的命令行参数全部传给该类实现。消息消费表示从 latest 位移位置开始消费该主题的所有分区消息,即仅消费正在写入的消息。bin/kafka-console-consumer.sh --bootstrap-
·
kafka-console-consumer.sh 脚本是一个简易的消费者控制台。该 shell 脚本的功能通过调用 kafka.tools 包下的 ConsoleConsumer 类,并将提供的命令行参数全部传给该类实现。
- 消息消费
表示从 latest 位移位置开始消费该主题的所有分区消息,即仅消费正在写入的消息。
bin/kafka-console-consumer.sh --bootstrap-server node1:9092,node2:9092,node3:9092 --topic topicName
- 从开始位置消费
表示从指定主题中有效的起始位移位置开始消费所有分区的消息。
bin/kafka-console-consumer.sh --bootstrap-server node1:9092,node2:9092,node3:9092 --from-beginning --topic topicName
- 显示key消费
消费出的消息结果将打印出消息体的 key 和 value
bin/kafka-console-consumer.sh --bootstrap-server node1:9092,node2:9092,node3:9092 --property print.key=true --topic topicName
-
添加其他属性参考原文链接:https://blog.csdn.net/qq_29116427/article/details/80206125
更多推荐
已为社区贡献4条内容
所有评论(0)