Hello Apache Kafka community, In new KafkaConsumer API on trunk, it seems it's only possible to define consumer group id at construction time of KafkaConsumer, through property with group.id key.
Would it make sense and be possible to support setting/changing consumer group id after construction, but before it's actually used for the first time, similar to how subscription is supported through "public void subscribe(String... topics)"? Maybe this can be done through additional method "public void subscribe(String consumerGroupId, String... topics)" which would first set provided consumer group id in coordinator and then call "public void subscribe(String... topics)". Kind regards, Stevo Slavic.
