查看kafka版本

kafka沒有提供version命令，但可以進入kafka/libs文件夾查看jar包，像kafka_2.12-1.1.0.jar，其中2.12是Scala版本，1.1.0是Kafka版本。

消費日志：

./kafka-console-consumer.sh --bootstrap-server 192.168.1.10:9092 --topic topic_ngxlog

 

查看 group 'monitor-consumer' 消費情況

./kafka-consumer-groups.sh --bootstrap-server 192.168.1.10:9092 --describe --group monitor-consumer

Note: This will not show information about old Zookeeper-based consumers.
Consumer group 'monitor-consumer' has no active members.

TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-ID
xxx　　xxx　　....