kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Stevo Slavić <ssla...@gmail.com>
Subject New consumer - consumer group init
Date Sat, 18 Jul 2015 06:13:23 GMT
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.

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