You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
When consumer with static subscription reconnect to kafka cluster then it can't subscribe to required topics.
How to reproduce
Create consumer with group.instance.id "instance1" then subscribe to topic "topic1". Do poll some messages. Subscribe to topic "topic2" and do poll some message. Then do hard disconnect/application shutdown.
Some time later restart consumer again with same sequence. After consumer subscribe to topic1 it poll messages from topic2 only not from topic1.
Workaround: Create a new static consumer on every restart [I use "group.instance.id": uuid.new().string()]
Checklist
Please provide the following information:
confluent-kafka-go and librdkafka version (LibraryVersion()): v2.3.0
Description
When consumer with static subscription reconnect to kafka cluster then it can't subscribe to required topics.
How to reproduce
Create consumer with group.instance.id "instance1" then subscribe to topic "topic1". Do poll some messages. Subscribe to topic "topic2" and do poll some message. Then do hard disconnect/application shutdown.
Some time later restart consumer again with same sequence. After consumer subscribe to topic1 it poll messages from topic2 only not from topic1.
Workaround: Create a new static consumer on every restart [I use "group.instance.id": uuid.new().string()]
Checklist
Please provide the following information:
LibraryVersion()
): v2.3.0ConfigMap{...}
"group.id": "group1", "group.instance.id": "instance1", "go.application.rebalance.enable": true, "enable.partition.eof": true, "enable.auto.offset.store": false, "enable.auto.commit": falseThe text was updated successfully, but these errors were encountered: