kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Guozhang Wang <wangg...@gmail.com>
Subject Re: New consumer - consumer group init
Date Sat, 18 Jul 2015 22:01:07 GMT
Hi Stevo,

Hmm this is interesting, do you have any use cases in mind that need
dynamic group changing?


On Fri, Jul 17, 2015 at 11:13 PM, Stevo Slavić <sslavic@gmail.com> 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

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message