Nodes being deleted from ZK should remove entries from the consumers map

reiseburo / verspaetung

Verspätung is a small utility which aims to help identify delay of Kafka consumers

http://reiseburo.github.io/verspaetung/

MIT License

11 stars 2 forks source link

Nodes being deleted from ZK should remove entries from the consumers map #14

Open rtyler opened 9 years ago

rtyler commented 9 years ago

After deleting a node for an invalid consumer in Zookeeper, the metrics being reported out of Verspaetung continued to be correct. I believe the TreeCache updated correctly but on a NODE_REMOVED event we're not removing the appropriate entry from the consumersmap