Kafka:常用查看命令


查看topic

bin/kafka-topics.sh \
--zookeeper emr-header-1:2181,emr-header-2:2181,emr-header-3:2181/kafka-1.0.1 \
--list

查看kafka的topic詳細信息

bin/kafka-topics.sh \
--zookeeper emr-header-1:2181,emr-header-2:2181,emr-header-3:2181/kafka-1.0.1 \
--topic T1 \
--describe

查看消費者組

bin/kafka-consumer-groups.sh \
--bootstrap-server 172.1.2.3:9092,172.1.2.4:9092,172.1.2.5:9092 \
--list

查看消費者組詳情

bin/kafka-consumer-groups.sh \
--bootstrap-server 172.1.2.3:9092,172.1.2.4:9092,172.1.2.5:9092 \
--group group_name1 \
--describe

查看__consumer_offsets中記載的偏移量數據

bin/kafka-console-consumer.sh --topic __consumer_offsets \
--bootstrap-server 172.1.2.3:9092,172.1.2.4:9092,172.1.2.5:9092 \
--formatter "kafka.coordinator.group.GroupMetadataManager\$OffsetsMessageFormatter" \
--consumer.config config/consumer.properties \
--from-beginning | grep group_name1 

查看topic信息最近5條

bin/kafka-console-consumer.sh \
--zookeeper emr-header-1:2181,emr-header-2:2181,emr-header-3:2181/kafka-1.0.1 \
--topic T2 \
--max-messages 5

指定消費者組消費主題數據:

bin/kafka-console-consumer.sh \
--bootstrap-server 172.1.2.3:9092,172.1.2.4:9092,172.1.2.5:9092 \
--topic T2 --group group_name1


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM