sanghyeok An created KAFKA-20889:
------------------------------------

             Summary: Consider rejecting empty group.instance.id values in 
Kafka Streams
                 Key: KAFKA-20889
                 URL: https://issues.apache.org/jira/browse/KAFKA-20889
             Project: Kafka
          Issue Type: Bug
            Reporter: sanghyeok An
            Assignee: sanghyeok An


ConsumerConfig only permits non-empty group.instance.id values, and a regular 
KafkaConsumer rejects an empty value with a ConfigException.

Kafka Streams currently appends the stream thread index before consumer 
validation. As a result:

group.instance.id="" → "-1", "-2", ...

These derived values pass validation and enable static membership. Multiple 
application instances may then generate the same instance IDs.

We should consider validating the base group.instance.id before appending the 
thread index and rejecting empty values consistently with ConsumerConfig. 
Unit-test coverage should be added if this behavior is changed.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to