| Interface | Description |
|---|---|
| KafkaOutbound<K,V> |
KafkaOutbound is a reactive gateway for outgoing data flows to Kafka. |
| KafkaSender<K,V> |
Reactive producer that sends outgoing records to topic partitions of a Kafka
cluster.
|
| SenderOptions<K,V> | |
| SenderOptions.ProducerListener |
Called whenever a producer is added or removed.
|
| SenderResult<T> |
Result metadata for an outbound record that was acknowledged by Kafka.
|
| TransactionManager |
| Class | Description |
|---|---|
| MicrometerProducerListener |
A producer listener that manages
KafkaClientMetrics. |
| SenderRecord<K,V,T> |
Represents an outgoing record.
|