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, 2016 at 9:29:22 AM, Bart Vercammen (b...@cloutrix.com) wrote: 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 that's able to reproduce the issue at hand. I'll also include some logs in my following posts. Thanks for the reply ... food for thought indeed ... On Mon, Nov 28, 2016 at 10:17 PM, Radek Gruchalski <ra...@gruchalski.com> wrote: > There has been plenty of changes in the GroupCoordinator and co between > these two releases: > https://github.com/apache/kafka/commit/40b1dd3f495a59abef8a0cba545052 > 6994c92c04#diff-96e4cf31cd54def6b2fb3f7a118c1db3 > > It might be related to this: > https://github.com/apache/kafka/commit/4b003d8bcfffded55a00b8ecc9eed8 > eb373fb6c7#diff-d2461f78377b588c4f7e2fe8223d5679R633 > > If your group is empty, your group is marked dead, when the group is dead, > no matter what you do, it’ll reply with: > https://github.com/apache/kafka/blob/trunk/core/src/ > main/scala/kafka/coordinator/GroupCoordinator.scala#L353 > > Food for thought. > > – > Best regards, > Radek Gruchalski > ra...@gruchalski.com > > > On November 28, 2016 at 9:04:16 PM, Bart Vercammen (b...@cloutrix.com) > wrote: > > 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 their hart-beat after a rebalance got > triggered. > In the logs on the consumer I can actually see that the heartbeat failed > due to "invalid member_id" > > When running the exact same code on a 0.10.0.1 setup, all works perfectly. > Anyone else seen this problem? > > Greets, > Bart > > -- Mvg, Bart Vercammen [image: Picture] clouTrix BVBA +32 486 69 17 68 i...@cloutrix.com
