aswinjoseroy

To see status of a Kafka Consumer Group's consumption status,

/bin/kafka-consumer-groups.sh --bootstrap-server server_ip:port --describe --group consumer_group_name | awk '{lag_sum += $5; total_sum += $4; done_sum += $3} END {print "Completed count: " done_sum ", Lag: " lag_sum ", Total number of records: " total_sum}'