Kafka Command

Version 2.1.0

kafka-consumer-groups.sh

kafka group

消費者組：list

$ ./kafka-consumer-groups.sh --bootstrap-server hadoop1:59092,hadoop2:59092,hadoop3:59092 --list trajectoryGroup myGroup

消費者組：state

$ ./kafka-consumer-groups.sh --bootstrap-server hadoop1:59092,hadoop2:59092,hadoop3:59092 --group trajectoryGroup --describe --stateCOORDINATOR (ID) ASSIGNMENT-STRATEGY STATE #MEMBERS hadoop1:59092 (0) range Stable 4

消費者組：describe

查看消息堆積

$ ./kafka-consumer-groups.sh --bootstrap-server hadoop1:59092,hadoop2:59092,hadoop3:59092 --group trajectoryGroup --describeTOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-ID xxx_trajectory 0 143693805 143693905 100 consumer-1-02f47385-5496-4094-9513-09c0b66b47bc /59.202.28.243 consumer-1 xxx_trajectory 1 137186261 137186348 87 consumer-1-02f47385-5496-4094-9513-09c0b66b47bc /59.202.28.243 consumer-1

消費者組：members

$ ./kafka-consumer-groups.sh --bootstrap-server hadoop1:59092,hadoop2:59092,hadoop3:59092 --group trajectoryGroup --describe --membersCONSUMER-ID HOST CLIENT-ID #PARTITIONS consumer-1-2de6119e-fc4f-41a6-baa1-a702665d9c6f /59.202.28.237 consumer-1 3 consumer-1-02f47385-5496-4094-9513-09c0b66b47bc /59.202.28.243 consumer-1 3

消費者組：members verbose

$ ./kafka-consumer-groups.sh --bootstrap-server hadoop1:59092,hadoop2:59092,hadoop3:59092 --group trajectoryGroup --describe --members --verboseCONSUMER-ID HOST CLIENT-ID #PARTITIONS ASSIGNMENT consumer-1-2de6119e-fc4f-41a6-baa1-a702665d9c6f /59.202.28.237 consumer-1 3 xxx_trajectory(3,4,5) consumer-1-02f47385-5496-4094-9513-09c0b66b47bc /59.202.28.243 consumer-1 3 xxx_trajectory(0,1,2)

kafka topic

主題：list

$ ./kafka-topics.sh --zookeeper hadoop1:2181,hadoop2:2181,hadoop3:2181/kafka_2.11-2.1.0 --list __consumer_offsets xxx_trajectory

主題：describe

查看主題分區信息、副本信息、同步副本信息

./kafka-topics.sh --zookeeper hadoop1:2181,hadoop2:2181,hadoop3:2181/kafka_2.11-2.1.0 --topic xxx_trajectory --describe Topic:xxx_trajectory PartitionCount:6 ReplicationFactor:2 Configs:Topic: xxx_trajectory Partition: 0 Leader: 2 Replicas: 2,1 Isr: 1,2Topic: xxx_trajectory Partition: 1 Leader: 2 Replicas: 0,2 Isr: 2,0Topic: xxx_trajectory Partition: 2 Leader: 1 Replicas: 1,0 Isr: 1,0Topic: xxx_trajectory Partition: 3 Leader: 2 Replicas: 2,0 Isr: 2,0Topic: xxx_trajectory Partition: 4 Leader: 1 Replicas: 0,1 Isr: 1,0Topic: xxx_trajectory Partition: 5 Leader: 1 Replicas: 1,2 Isr: 1,2

kafka console consumer

控制臺消費者：

控制臺命令行消費者：消費主題消息

$ ./kafka-console-consumer.sh --zookeeper hadoop4:59092,hadoop5:59092,hadoop6:59092 --topic xxx_trajectory --describe

總結

以上是生活随笔為你收集整理的Kafka 常见命令行 Version 2.1.0的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。