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/03 16:17:06 UTC

[GitHub] [beam] kennknowles opened a new issue, #18086: KafkaIO should support dynamic addition of Kafka partitions to assigned topics.

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

   Kafka topics may add partitions dynamically (doesn't require Kafka to restart, or halt a topic), and the KafkaIO should probably support this.
   
   *Note:* 
   Consistently assigning partitions should be taken into account, specifically for the case of reading from multiple topics, where one (or more) of the topics added partitions while the pipeline is running.
   
   
   
   Imported from Jira [BEAM-727](https://issues.apache.org/jira/browse/BEAM-727). Original Jira may contain additional context.
   Reported by: amitsela.


-- 
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