reactor.kafka.sender

Interface SenderResult<T>

public interface SenderResult<T>

Result metadata for an outbound record that was acknowledged by Kafka. This result also includes the correlation metadata provided in SenderRecord that was not sent to Kafka, but enables matching this response to its corresponding request.

Results are published when the send is acknowledged based on the acknowledgement mode configured using the option ProducerConfig.ACKS_CONFIG. If acks is not zero, sends are retried if ProducerConfig.RETRIES_CONFIG is configured.

Method Summary

Modifier and Type	Method and Description
T	correlationMetadata() Returns the correlation metadata associated with this instance to enable this result to be matched with the corresponding SenderRecord that was sent to Kafka.
Exception	exception() Returns the exception associated with a send failure.
org.apache.kafka.clients.producer.RecordMetadata	recordMetadata() Returns the record metadata returned by Kafka.

Method Detail

recordMetadata

org.apache.kafka.clients.producer.RecordMetadata recordMetadata()

Returns the record metadata returned by Kafka. May be null if send request failed. See exception() for failure reason when record metadata is null.

Returns:

response metadata from Kafka Producer

exception

Exception exception()

Returns the exception associated with a send failure. This is set to null for successful responses.

Returns:

send exception from Kafka Producer if send did not succeed even after the configured retry attempts.

correlationMetadata

T correlationMetadata()

Returns the correlation metadata associated with this instance to enable this result to be matched with the corresponding SenderRecord that was sent to Kafka.

Returns:

correlation metadata