查看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