列出所有主题
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