Skip to content
This repository has been archived by the owner on Jan 26, 2018. It is now read-only.

Consumer isn't working in 0.7.5 #6

Open
No9 opened this issue Jun 24, 2013 · 3 comments
Open

Consumer isn't working in 0.7.5 #6

No9 opened this issue Jun 24, 2013 · 3 comments

Comments

@No9
Copy link

No9 commented Jun 24, 2013

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
Copy link
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
Copy link

tvpavan commented Jul 17, 2013

I too face this issue.

@stevenluan
Copy link
Contributor

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 subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
None yet
Projects
None yet
Development

No branches or pull requests

4 participants