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