[CAMEL-16719] camel-kafka - Add option to configure group instance id

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 3.11.0
• Component/s: camel-kafka
• Estimated Complexity: Unknown
• Assignee: Unassigned
• Reporter: Claus Ibsen
• Created: 12/Jun/21 08:56
• Updated: 15/Jun/21 05:37
• Resolved: 15/Jun/21 05:37

Description

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.";