reactor.kafka.receiver

Class ReceiverRecord<K,V>

java.lang.Object

org.apache.kafka.clients.consumer.ConsumerRecord<K,V>

reactor.kafka.receiver.ReceiverRecord<K,V>

Type Parameters:

K - Incoming record key type

V - Incoming record value type

public class ReceiverRecord<K,V>
extends ConsumerRecord<K,V>

Represents an incoming record dispatched by KafkaReceiver.

Field Summary

Fields inherited from class org.apache.kafka.clients.consumer.ConsumerRecord

NO_TIMESTAMP, NULL_CHECKSUM, NULL_SIZE

Constructor Summary

Constructors

Constructor and Description
ReceiverRecord(ConsumerRecord<K,V> consumerRecord, ReceiverOffset receiverOffset)

Method Summary

Modifier and Type	Method and Description
ReceiverOffset	receiverOffset() Returns an acknowledgeable offset instance that should be acknowledged after this record has been consumed.

Methods inherited from class org.apache.kafka.clients.consumer.ConsumerRecord

checksum, headers, key, offset, partition, serializedKeySize, serializedValueSize, timestamp, timestampType, topic, toString, value

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ReceiverRecord

public ReceiverRecord(ConsumerRecord<K,V> consumerRecord,
                      ReceiverOffset receiverOffset)

Method Detail

receiverOffset

public ReceiverOffset receiverOffset()

Returns an acknowledgeable offset instance that should be acknowledged after this record has been consumed. Acknowledged records are automatically committed based on the commit batch size and commit interval configured for the KafkaReceiver. Acknowledged records may be also committed using ReceiverOffset.commit().

Returns:

offset to acknowledge after record is processed