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

Posted to commits@beam.apache.org by "Raghu Angadi (JIRA)" <ji...@apache.org> on 2017/03/29 15:05:41 UTC

[jira] [Created] (BEAM-1830) add 'withTopic()' api to KafkaIO Reader

Raghu Angadi created BEAM-1830:
----------------------------------

             Summary: add 'withTopic()' api to KafkaIO Reader
                 Key: BEAM-1830
                 URL: https://issues.apache.org/jira/browse/BEAM-1830
             Project: Beam
          Issue Type: Improvement
          Components: sdk-java-extensions
    Affects Versions: 0.6.0
            Reporter: Raghu Angadi
            Assignee: Raghu Angadi
            Priority: Minor
             Fix For: First stable release


Most of instances of KafkaIO readers consume just one topic. The existing method {{withTopics(List<String> topics)}} forces the users to make a list containing single topic.

It would be simpler to add {{withTopic(String topic)}} method.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)