Monitor the Consumer Lag in Apache Kafka