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

• KafkaIO.java