-
-
Notifications
You must be signed in to change notification settings - Fork 579
Description
We are currently using Apache Kafka 2.2 with KafkaJS 1.5 in our project.
As we plan to upgrade to Apache Kafka 2.3 and above, we’ve encountered an issue: KafkaJS does not seem to support the group.instance.id configuration for consumers.
Starting with Kafka 2.3, the group.instance.id property is used to enable static membership in consumer groups, which helps prevent unnecessary rebalances when consumers restart.
However, this feature does not appear to be supported in KafkaJS, even with the latest version.
Expected Behavior:
KafkaJS should support the group.instance.id configuration for consumers when using Apache Kafka 2.3 and above, enabling static membership functionality as designed in Kafka 2.3+.
Actual Behavior:
KafkaJS does not expose a way to configure group.instance.id for consumers, preventing us from using static membership introduced in Kafka 2.3 and later.
Questions:
Is there a way or workaround to set group.instance.id in KafkaJS consumers?
If not, are there plans to add support for this configuration in an upcoming release?