Re: Kafka 0.10.1.0 consumer group rebalance broken?

2016-11-29 Thread Radek Gruchalski
You’re most likely correct that it’s not that particular change. That commit was introduced only 6 days ago, well after releasing 0.10.1. An mvp would be helpful. Unless someone else on this list knows the issue immediately. – Best regards, Radek Gruchalski ra...@gruchalski.com On November 29,

Re: Kafka 0.10.1.0 consumer group rebalance broken?

2016-11-29 Thread Bart Vercammen
Well, well, mr. Gruchalski, always nice to talk to you ;-) Not sure whether it is indeed related to: https://github.com/apache/kafka/commit/4b003d8bcfffded55a00b8ecc9eed8 eb373fb6c7#diff-d2461f78377b588c4f7e2fe8223d5679R633 But I'll have a look and will try to create a test scenario for this

Re: Kafka 0.10.1.0 consumer group rebalance broken?

2016-11-28 Thread Radek Gruchalski
There has been plenty of changes in the GroupCoordinator and co between these two releases: https://github.com/apache/kafka/commit/40b1dd3f495a59abef8a0cba5450526994c92c04#diff-96e4cf31cd54def6b2fb3f7a118c1db3 It might be related to this:

Kafka 0.10.1.0 consumer group rebalance broken?

2016-11-28 Thread Bart Vercammen
Hi, It seems that consumer group rebalance is broken in Kafka 0.10.1.0 ? When running a small test-project : - consumers running in own JVM (with different 'client.id') - producer running in own JVM - kafka broker : the embedded kafka : KafkaServerStartable It looks like the consumers loose