Package org.apache.beam.sdk.io.kafka

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).

Constructor Summary

Constructors

Constructor	Description
KafkaRecord(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

Modifier and Type	Method	Description
boolean	equals(@Nullable Object obj)
@Nullable Headers	getHeaders()
KV<K,V>	getKV()
long	getOffset()
int	getPartition()
long	getTimestamp()
KafkaTimestampType	getTimestampType()
String	getTopic()
int	hashCode()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Constructor Details

KafkaRecord

public KafkaRecord(String topic,
 int partition,
 long offset,
 long timestamp,
 KafkaTimestampType timestampType,
 @Nullable Headers headers,
 K key,
 V value)

KafkaRecord

public KafkaRecord(String topic,
 int partition,
 long offset,
 long timestamp,
 KafkaTimestampType timestampType,
 @Nullable Headers headers,
 KV<K,V> kv)

Method Details

getTopic

public String getTopic()

getPartition

public int getPartition()

getOffset

public long getOffset()

getHeaders

@Pure
public @Nullable Headers getHeaders()

getKV

public KV<K,V> getKV()

getTimestamp

public long getTimestamp()

getTimestampType

public KafkaTimestampType getTimestampType()

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(@Nullable Object obj)

Overrides:

equals in class Object