franz-kafka
franz-kafka copied to clipboard
Consumer isn't working in 0.7.5
As per this comment https://github.com/dannycoates/franz-kafka/pull/4#issuecomment-19424224
I am using kafka 0.7.2 and I seeing a similar issue. i.e. no errors reported but no data being received.
I'm not actively using Kafka right now, so I haven't been maintaining very well. I'll try to look at this soon.
I too face this issue.
there is one bug in zk.js line 406 which caused this issue, it uses wrong counter,
pasted code below, var topicName = topicNames[j] will fix the issue
for (var i = 0; i < consumerIds.length; i++) { var consumerId = consumerIds[i] var consumer = consumerTopicCounts[consumerId] consumerTopicPartitions[consumerId] = {}
for (var j = 0; j < topicNames.length; j++) {
var topicName = topicNames[i]