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

Posted to commits@beam.apache.org by "Amit Sela (JIRA)" <ji...@apache.org> on 2016/10/07 10:06:20 UTC

[jira] [Updated] (BEAM-727) KafkaIO should support dynamic addition of Kafka partitions to assigned topics.

     [ https://issues.apache.org/jira/browse/BEAM-727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Amit Sela updated BEAM-727:
---------------------------
    Assignee:     (was: James Malone)

> KafkaIO should support dynamic addition of Kafka partitions to assigned topics. 
> --------------------------------------------------------------------------------
>
>                 Key: BEAM-727
>                 URL: https://issues.apache.org/jira/browse/BEAM-727
>             Project: Beam
>          Issue Type: Improvement
>          Components: sdk-java-extensions
>            Reporter: Amit Sela
>            Priority: Minor
>
> 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.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)