kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Bart Vercammen <b...@cloutrix.com>
Subject Kafka 0.10.1.0 consumer group rebalance broken?
Date Mon, 28 Nov 2016 20:04:10 GMT
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

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message