GitHub user rangadi opened a pull request:
https://github.com/apache/beam/pull/2364
[BEAM-1830] KafkaIO : Add withTopic() api that takes single topic.
Overwhelming uses of KafkaIO consume just one topic. It would be nice to
have `withTopic(topic)` rather than always requiring a list.
In addition, I am fixing a small bug I noticed while using
`KafkaIO.write().values()`. Remove need for setting key coder for Writer while
writing values only. If we didn't specifiy the key coder, validation succeeded
but it failed a check while instantiating Kafka producer.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rangadi/incubator-beam with_topic
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/beam/pull/2364.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #2364
----
commit d958c7bdb14ea42f80b955a94fd9d4f6b1b870fc
Author: Raghu Angadi <[email protected]>
Date: 2017-03-29T15:17:25Z
KafkaIO : Add withTopic() api that takes single topic.
Remove need for setting key coder for Writer while writing
values only. If we didn't specifiy the key coder, validation
succeeded but it failed a check while instantiating Kafka producer.
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
