Hi Stevo, Hmm this is interesting, do you have any use cases in mind that need dynamic group changing?
Guozhang On Fri, Jul 17, 2015 at 11:13 PM, Stevo Slavić <[email protected]> wrote: > 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. > -- -- Guozhang
