Interface | Description |
---|---|
KafkaReceiver<K,V> |
A reactive Kafka receiver for consuming records from topic partitions
of a Kafka cluster.
|
ReceiverOffset |
Topic partition offset that must be acknowledged after the record in the
corresponding
ReceiverRecord is processed. |
ReceiverOptions<K,V> | |
ReceiverPartition |
Topic partition interface that supports
seek operations
that can be invoked when partitions are assigned. |
Class | Description |
---|---|
ReceiverRecord<K,V> |
Represents an incoming record dispatched by
KafkaReceiver . |