Class KafkaRecord<K,V>

java.lang.Object
org.apache.beam.sdk.io.kafka.KafkaRecord<K,V>

public class KafkaRecord<K,V> extends Object
KafkaRecord contains key and value of the record as well as metadata for the record (topic name, partition id, and offset).