Developed an observability enhancement for the restatedev/restate repository by implementing Kafka Consumer Lag Monitoring using Rust. This feature introduced a gauge metric to track consumer lag at the topic and partition level, enabling real-time visibility into message backlog. The approach involved creating an update_consumer_stats function to process Kafka client statistics, extract lag data, and expose these metrics for system monitoring and proactive backlog detection. Leveraging expertise in Kafka, metrics, and system monitoring, the work improved operational readiness by supporting alerting on lag and facilitating adherence to service level agreements, ultimately reducing the risk of lag-related incidents in production environments.