Open baconalot opened 9 years ago
Can you try #72 by any chance? The way the rebalance works has been improved significantly.
hi wvanbergen
I tried to run #72 but found it only work with kafka 0.8.2 because of sarama's Client.Coordinator in interface Client. is it necessary?
// Coordinator returns the coordinating broker for a consumer group. It will return a locally cached // value if it's available. You can call RefreshCoordinator to update the cached value. // This function only works on Kafka 0.8.2 and higher. Coordinator(consumerGroup string) (*Broker, error)
Yes; the new implementation uses Kafka to commit processed offsets, which requires 0.8.2. I may add Zookeeper support but for now that is not really on my list.
If you can't upgrade to Kafka 0.8.2, make sure you're using the latest master version of consumergroup
, because a bunch of bugs were recently fixed in it's implementation which may have been the cause of this panic.
we can not upgrade to 0.8.2 but thank you for your work after all
在 2015年8月26日,17:14,Willem van Bergen notifications@github.com 写道:
Yes; the new implementation uses Kafka to commit processed offsets, which requires 0.8.2. I may add Zookeeper support but for now that is not really on my list.
If you can't upgrade to Kafka 0.8.2, make sure you're using the latest master version of consumergroup, because a bunch of bugs were recently fixed in it's implementation which may have been the cause of this panic.
— Reply to this email directly or view it on GitHub.
Given the following test program:
With topic
testproducercango
having 20 messages calledbladiebla1...bladiebla20
in 2 partitions. I get the following output when I start this program4
times in parallel. Pid 0:Pid 1:
Pid 2:
Pid 3:
Issues in bold. For now I see two:
markAsProcessed
acts on already closed partition