org.wikimedia.gobblin.copy

Class Kafka1ConsumerClient.Kafka1ConsumerRecord<K,V>

java.lang.Object

org.apache.gobblin.kafka.client.BaseKafkaConsumerRecord

org.wikimedia.gobblin.copy.Kafka1ConsumerClient.Kafka1ConsumerRecord<K,V>

Type Parameters:

K - Message key type

V - Message value type

All Implemented Interfaces:

org.apache.gobblin.kafka.client.DecodeableKafkaRecord<K,V>, org.apache.gobblin.kafka.client.KafkaConsumerRecord

Enclosing class:

Kafka1ConsumerClient<K,V>

public static class Kafka1ConsumerClient.Kafka1ConsumerRecord<K,V>
extends org.apache.gobblin.kafka.client.BaseKafkaConsumerRecord
implements org.apache.gobblin.kafka.client.DecodeableKafkaRecord<K,V>

A record returned by Kafka1ConsumerClient

Field Summary

Fields inherited from class org.apache.gobblin.kafka.client.BaseKafkaConsumerRecord

VALUE_SIZE_UNAVAILABLE

Constructor Summary

Constructors

Constructor and Description
Kafka1ConsumerRecord(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> consumerRecord)

Method Summary

Modifier and Type	Method and Description
K	getKey()
long	getTimestamp()
org.apache.kafka.common.record.TimestampType	getTimestampType()
V	getValue()
boolean	isTimestampLogAppend()

Methods inherited from class org.apache.gobblin.kafka.client.BaseKafkaConsumerRecord

canEqual, equals, getNextOffset, getOffset, getPartition, getTopic, getValueSizeInBytes, hashCode, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.gobblin.kafka.client.KafkaConsumerRecord

getNextOffset, getOffset, getPartition, getRecordCreationTimestamp, getTopic, getValueSizeInBytes

Constructor Detail

Kafka1ConsumerRecord

public Kafka1ConsumerRecord(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> consumerRecord)

Method Detail

getTimestampType

public org.apache.kafka.common.record.TimestampType getTimestampType()

Returns:

the timestamp type of the underlying ConsumerRecord (only for Kafka 1+ records)

isTimestampLogAppend

public boolean isTimestampLogAppend()

Specified by:

isTimestampLogAppend in interface org.apache.gobblin.kafka.client.KafkaConsumerRecord

Returns:

true if the timestamp in the ConsumerRecord is the timestamp when the record is written to Kafka.

getTimestamp

public long getTimestamp()

Specified by:

getTimestamp in interface org.apache.gobblin.kafka.client.KafkaConsumerRecord

Returns:

the timestamp of the underlying ConsumerRecord. NOTE: check TimestampType

getKey

public K getKey()

Specified by:

getKey in interface org.apache.gobblin.kafka.client.DecodeableKafkaRecord<K,V>

getValue

public V getValue()

Specified by:

getValue in interface org.apache.gobblin.kafka.client.DecodeableKafkaRecord<K,V>