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