Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP

Loading…

Consumer isn't working in 0.7.5 #6

Open
No9 opened this Issue · 3 comments

4 participants

@No9

As per this comment #4 (comment)

I am using kafka 0.7.2 and I seeing a similar issue. i.e. no errors reported but no data being received.

@dannycoates
Owner

I'm not actively using Kafka right now, so I haven't been maintaining very well. I'll try to look at this soon.

@tvpavan

I too face this issue.

@stevenluan

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]
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Something went wrong with that request. Please try again.