You are viewing a plain text version of this content. The canonical link for it is here.

Posted to github@beam.apache.org by GitBox <gi...@apache.org> on 2022/06/04 15:37:04 UTC

[GitHub] [beam] damccorm opened a new issue, #20159: KafkaIO supports consumer group?

damccorm opened a new issue, #20159:
URL: https://github.com/apache/beam/issues/20159

   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?
   
    
   
   Imported from Jira [BEAM-9760](https://issues.apache.org/jira/browse/BEAM-9760). Original Jira may contain additional context.
   Reported by: wongkawah.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: github-unsubscribe@beam.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org