kafka_message_queue_time
Time a message spent in Kafka queue before being consumedDimensions:None
Interface Metrics (2)
Native
Time a message spent in Kafka queue before being consumedDimensions:None
Related Insights (2)
Ingestion Source Backpressure from Sink Write Throttlingwarning
DataHub ingestion pipelines stall when sink write rate (sink_workunits_write) lags significantly behind source production rate (source_workunits_produced). This indicates downstream storage systems (Elasticsearch, database) cannot keep pace with ingestion volume.
▸
Kafka Consumer Lag Ingestion Backlogcritical
DataHub ingestion falling behind due to Kafka consumer lag, causing metadata changes and quality checks to be delayed, leading to stale lineage and undetected data quality issues.
▸