Claus Ibsen created CAMEL-16719:
-----------------------------------
Summary: camel-kafka - Add option to configure group instance id
Key: CAMEL-16719
URL: https://issues.apache.org/jira/browse/CAMEL-16719
Project: Camel
Issue Type: Improvement
Components: camel-kafka
Reporter: Claus Ibsen
Fix For: 3.11.0
https://camel.zulipchat.com/#narrow/stream/257298-camel/topic/Kafka.3A.20Group.20Instance.20id
Add this as endpoint option for the consumer
public static final String GROUP_INSTANCE_ID_CONFIG = "group.instance.id";
private static final String GROUP_INSTANCE_ID_DOC = "A unique identifier of
the consumer instance provided by the end user. Only non-empty strings are
permitted. If set, the consumer is treated as a static member, which means that
only one instance with this ID is allowed in the consumer group at any time.
This can be used in combination with a larger session timeout to avoid group
rebalances caused by transient unavailability (e.g. process restarts). If not
set, the consumer will join the group as a dynamic member, which is the
traditional behavior.";
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
