You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@camel.apache.org by "Claus Ibsen (Jira)" <ji...@apache.org> on 2021/06/12 08:57:00 UTC

[jira] [Created] (CAMEL-16719) camel-kafka - Add option to configure group instance id

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)