reactor.kafka.receiver

Interface ReceiverRecord<K,V>

Type Parameters:

K - Incomimg record key type

V - Incomimg record value type

public interface ReceiverRecord<K,V>

Represents an incoming record dispatched by Receiver.

Method Summary

Modifier and Type	Method and Description
ReceiverOffset	offset() Returns an acknowledgeable offset instance that should be acknowledged after this record has been consumed.
ConsumerRecord<K,V>	record() Returns the Kafka consumer record associated with this instance.

Method Detail

record

ConsumerRecord<K,V> record()

Returns the Kafka consumer record associated with this instance.

Returns:

consumer record from kafka

offset

ReceiverOffset offset()

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 Receiver. Acknowledged records may be also committed using ReceiverOffset.commit().

Returns:

offset to acknowledge after record is processed