有时需要简单的用shell去检查一个topic下边某一个partition的某个offset的消息。
之前一直用 kafka.tools.ConsoleConsumer， 用的心酸。
后来发现一个稍强大的工具。
https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example
sample usage:
kafka-run-class.sh kafka.tools.SimpleConsumerShell
--broker-list 'xxxx:9092'
--topic 'xxx.xxx.xx.xx'
--max-messages 1
--offset 12345
--partition 1
其他命令：
kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 'xxxx:9092' --topic 'xxxx' --time -1
有时需要简单的用shell去检查一个topic下边某一个partition的某个offset的消息。 之前一直用 ...
实际场景 在创建kafka的topic时，一般会指定partition以及其副本数，kafka会自动将这些part...
一、常用shell命令 1. 列出所有topic 2. 查看kafka版本 3. 查看offset
一、kafka 1、kafka消息模型总结 发送消息到topic，每个topic可以分成多个Partition，每...
摘自： Kafka quick start 目标：了解Kafka的基本概念：topic，partition，bro...
1.查看指定topic对应分区的offset 2.启动kafka 3. kafka相关命令 http://blog...
kafka是怎么通过偏移量找到对应的消息？首先消费者消费时会指定Topic和Partition，每个Partiti...
Kafka Shell基本命令（包括topic的增删改查） 创建kafka topic 注： partitions...
Kafka 中topic、Partition以及Broker之间的关系： 一个Topic可以分成多个Partion...
docker运行Kafka kafka操作命令 进入容器 创建topic 查看topic 删除topic 启动生产...
本文标题：Kafka shell 查看指定topic partition
本文链接：https://www.haomeiwen.com/subject/qzdrrxtx.html
网友评论