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)
