Please add an option for group.instance.id support
metalshanked opened this issue · 1 comments
metalshanked commented
Hi
Kafka static membership is a new feature introduced with Kafka 2.3. It allows the coordinator to persist member identities and to recognize restarted members. This is possible via the consumer configuration group.instance.id. If a consumer restarts for any reason, the group coordinator can assign the same partitions to the consumer without rebalancing everything.
Can we add this very useful option to the Kafka Input Plugin for Logstash?
Thanks in advance!