Hi Joey,
you should take a look on the Javadoc: it's where you will find the most
accurate doc.
https://beam.apache.org/documentation/sdks/javadoc/2.0.0/org/apache/beam/sdk/io/kafka/KafkaIO.html
Regards
JB
On 08/29/2017 10:28 AM, Joey Baruch wrote:
Hey all,
As a new user trying to use a kafkaIO source/sink i couldn't find any
documentation easily.
The documentation page <https://beam.apache.org/documentation/io/built-in/>,
(which you get to from headder -> doccumentaton -> pipeline i/o -> built in
i/o transforms) leads to the kafka class
<https://github.com/apache/beam/tree/master/sdks/java/io/kafka>, but there
is no docs there.
I will add a simple readme that points to the classe's javadocs.
regards
Joey Baruch
--
Jean-Baptiste Onofré
jbono...@apache.org
http://blog.nanthrax.net
Talend - http://www.talend.com
