列出所有主題
bin/kafka-topics.sh --bootstrap-server 10.150.171.147:9092 --list
查看 kafka 消費者組列表：
bin/kafka-consumer-groups.sh --bootstrap-server 10.150.171.147:9092 --list
查看消費者某一個group消費詳情
bin/kafka-consumer-groups.sh --bootstrap-server 10.150.171.147:9092 --group event_bing --describe
TOPIC |
PARTITION |
CURRENT-OFFSET |
LOG-END-OFFSET |
LAG |
CONSUMER-ID |
HOST |
CLIENT-ID |
|---|---|---|---|---|---|---|---|
| topic名字 | 分區id | 當前已消費的條數 | 總條數 | 未消費的條數 | 消費id | 主機ip | 客戶端id |
查看kafka消息
bin/kafka-console-consumer.sh --bootstrap-server 10.150.171.147:9092 --topic event_hendler_bing --from-beginning
bin/kafka-console-consumer.sh --zookeeper 127.0.0.1:9092 --topic event_hendler_bing --from-beginning | grep "message"
主題列表
bin/kafka-topics.sh --bootstrap-server localhost:9092 --list
發送消息
bin/kafka-console-producer.sh --broker-list 1.168.1.130:9092 --topic test