KafkaIO contains I/O transforms which allow you to read/write messages from/to Apache Kafka.
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>