kafka查看消息高级用法

 
1.查找全部
bin/kafka-console-consumer.sh --zookeeper 130.51.23.95:2181 --topic test --from-beginnin
 
2.从某台机器的某个patition按offset查找
/data/kafka_2.11-1.1.0/bin/kafka-console-consumer.sh --bootstrap-server X.X.X.X:9092  --topic test  --new-consumer --partition 1  --offset 2 |grep '1'
 
3.直接查询log文件
./kafka-run-class.sh kafka.tools.DumpLogSegments --files /data/log/kafka/test-1/00000000000000000000.log --print-data-log >/data/1.txt

 /data/kafka_2.11-1.1.0/bin/kafka-run-class.sh kafka.tools.DumpLogSegments --files /data/log/kafka/test-1/00000000000000000000.log --print-data-log | grep '你好'



 

相关推荐