tree: 3a027a8a0449ccd08eaf26832c6584167d345061 [path history] [tgz]
  1. src/
  2. pom.xml
  3. README.md
sdks/java/io/kafka/README.md

KafkaIO contains I/O transforms which allow you to read/write messages from/to Apache Kafka.

Dependencies

To use KafkaIO you must first add a dependency on beam-sdks-java-io-kafka

<dependency>
    <groupId>org.apache.beam</groupId>
    <artifactId>beam-sdks-java-io-kafka</artifactId>
    <version>...</version>
</dependency>

Documentation