Thursday, May 19, 2016

Check Kafka offset lag

To check Kafka's offset lag, use the following command:

$ ./bin/kafka-consumer-offset-checker.sh --broker-info --group test-group --zookeeper localhost:2181 --topic test-topic
[2016-05-19 16:57:30,771] WARN WARNING: ConsumerOffsetChecker is deprecated and will be dropped in releases following 0.9.0. Use ConsumerGroupCommand instead. (kafka.tools.ConsumerOffsetChecker$)
Group           Topic                          Pid Offset          logSize         Lag             Owner
test            test-topic                     0   294386          4349292         4054906         none
BROKER INFO
0 -> 1.2.3.4:9092
$

No comments:

Post a Comment