Comments (4)
Can you try #72 by any chance? The way the rebalance works has been improved significantly.
from kafka.
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)
from kafka.
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.
from kafka.
we can not upgrade to 0.8.2
but thank you for your work after all
在 2015年8月26日,17:14,Willem van Bergen [email protected] 写道:
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.
from kafka.
Related Issues (20)
- zk: node does not exist HOT 1
- Is There Any Benchmark for the Consumer? HOT 1
- Lots of logs such as "abandoned subscription to xxx because consuming was taking too long" HOT 1
- Bug? Consuming stops or hangs at certain time.
- ConsumerGroup.Messages() HOT 3
- How to exit the program in kafka/examples/consumergroup/main.go gracefully? HOT 1
- Clarify Kafka version support HOT 3
- consumption message delay
- consumergroup not work in docker HOT 1
- Consumer group not consuming from partitions -- Kafka v11
- Some problems when I try to run my consumer in two node. HOT 3
- Trouble reliably reusing consumer group names across topics HOT 1
- Upgrading to kafka based offset storage HOT 1
- Kafka consumer not restarting after broker failure
- Leader change during re-balance may cause partition not being consumed HOT 4
- Can't receive messages when i test the demo which the project gives. HOT 4
- ConsumerGroup.FlushOffsets() HOT 3
- Version releases? HOT 2
- which tag or version support kafka 0.8 ?
- Is there any way to get to the ConsumerGroup. Instance. ID?
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from kafka.