openstack
/
monasca-agent
Code Issues Proposed changes

Kafka plugin not tracking consumer lag 

A recent change caused our kafka consumer offset to get stuck at 0.  This
resulted in our kafka.consumer_lag measurement not properly tracking the
consumer offset.

Change-Id: I76f5ac912a0b27818b2311d5d9eaf0119a2019d2
Closes-Bug:#1567057
This commit is contained in:
Joe Keen 2016-04-06 14:29:16 -06:00
parent 6f59dd31d6
commit 5e71ddaf54
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
monasca_agent/collector/checks_d/kafka_consumer.py
View File

@ -76,6 +76,7 @@ class KafkaCheck(checks.AgentCheck):
consumer_group,
topic,
auto_commit=False)
kafka_consumer.fetch_last_known_offsets()
partitions = kafka_consumer.offsets.keys()
except Exception: