wvanbergen / kafka

Load-balancing, resuming Kafka consumer for go, backed by Zookeeper.
MIT License
373 stars 141 forks source link

added InstanceRegistered #59

Closed fayizk1 closed 9 years ago

fayizk1 commented 9 years ago

This will be helpful to identify a case where instance entry got removed from zookeepr.

something like this:

[Sarama] 2015/05/25 15:20:42 [logstash/7b49b9093ec8] Currently registered consumers: 1
[Sarama] 2015/05/25 15:20:42 [logstash/7b49b9093ec8] logs :: Started topic consumer
[Sarama] 2015/05/25 15:20:42 [logstash/7b49b9093ec8] logs :: Claiming 0 of 20 partitions