[
https://issues.apache.org/jira/browse/BEAM-9760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ka Wah WONG updated BEAM-9760:
------------------------------
Description:
It seems only assign method of Kafka Consumer class is called in
org.apache.beam.sdk.io.kafka.ConsumerSpEL class. According to documentation of
org.apache.kafka.clients.consumer.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?
was:
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?
> 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
> Priority: Minor
>
> It seems only assign method of Kafka Consumer class is called in
> org.apache.beam.sdk.io.kafka.ConsumerSpEL class. According to documentation
> of org.apache.kafka.clients.consumer.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)
