Package org.apache.beam.sdk.io.kafka
Class KafkaRecord<K,V>
java.lang.Object
org.apache.beam.sdk.io.kafka.KafkaRecord<K,V>
KafkaRecord contains key and value of the record as well as metadata for the record (topic name,
partition id, and offset).
-
Constructor Summary
ConstructorsConstructorDescriptionKafkaRecord
(String topic, int partition, long offset, long timestamp, KafkaTimestampType timestampType, @Nullable Headers headers, K key, V value) KafkaRecord
(String topic, int partition, long offset, long timestamp, KafkaTimestampType timestampType, @Nullable Headers headers, KV<K, V> kv) -
Method Summary
-
Constructor Details
-
KafkaRecord
-
KafkaRecord
-
-
Method Details