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>