Ka Wah WONG created BEAM-9760:
---------------------------------
Summary: KafkaIO supports consumer group?
Key: BEAM-9760
URL: https://issues.apache.org/jira/browse/BEAM-9760
Project: Beam
Issue Type: Improvement
Components: io-java-kafka
Reporter: Ka Wah WONG
It seems only assign method is called in
org.apache.beam.sdk.io.kafka.ConsumerSpEL class. According to documentation of
KafkaConsumer, manual topic assignment through this assign method does not use
the consumer's group management functionality.
May I ask if KafkaIO will be enhanced to support consumer's group management
with using Kafka consumer's subscribe method?
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
