| 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> | |
| ReceiverOptions.ConsumerListener |
Called whenever a consumer is added or removed.
|
| ReceiverPartition |
Topic partition interface that supports
seek operations
that can be invoked when partitions are assigned. |
| Class | Description |
|---|---|
| MicrometerConsumerListener |
A consumer listener that manages
KafkaClientMetrics. |
| ReceiverRecord<K,V> |
Represents an incoming record dispatched by
KafkaReceiver. |