查看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.
kafka命令TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-ID
xxx xxx ....
版权声明:本站内容均来自互联网,仅供演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198,我们将在24小时内删除。
发表评论