Re: kafka docs

2017-08-30 Thread Joey Baruch
Hey Raghu, After discussing with Aviem Zur, it made more sense to add a readme file at the kafka directory . PR is closed. Thanks On Tue, Aug 29, 2017, 8:51 PM Raghu Angadi wrote: > Thanks Joey. > I couldn't find the PR. Do you have

Re: kafka docs

2017-08-29 Thread Raghu Angadi
Thanks Joey. I couldn't find the PR. Do you have a link? On Tue, Aug 29, 2017 at 1:48 AM, Joey Baruch wrote: > created pr on the beam site (just reference change for now, as Jean > Baptiste wrote) > > Thanks Aviem! > > On Tue, Aug 29, 2017 at 11:46 AM Aviem Zur wrote: > > > Hi Joey. > > > > Th

Re: kafka docs

2017-08-29 Thread Joey Baruch
created pr on the beam site (just reference change for now, as Jean Baptiste wrote) Thanks Aviem! On Tue, Aug 29, 2017 at 11:46 AM Aviem Zur wrote: > Hi Joey. > > This would be great. Also, KafkaIO requires a specific dependency to be > added (beam-sdks-java-io-kafka), we should probably put th

Re: kafka docs

2017-08-29 Thread Aviem Zur
Hi Joey. This would be great. Also, KafkaIO requires a specific dependency to be added (beam-sdks-java-io-kafka), we should probably put that as a maven snippet in the README as well. Feel free to create a PR with this README on GitHub. Regarding the long series of links you need to click in the

Re: kafka docs

2017-08-29 Thread Jean-Baptiste Onofré
Agree to add the link to javadoc on the I/O list: https://beam.apache.org/documentation/io/built-in/ 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

Re: kafka docs

2017-08-29 Thread Jean-Baptiste Onofré
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 ka

kafka docs

2017-08-29 Thread Joey Baruch
Hey all, As a new user trying to use a kafkaIO source/sink i couldn't find any documentation easily. The documentation page , (which you get to from headder -> doccumentaton -> pipeline i/o -> built in i/o transforms) leads to the kafka class