diff --git a/src/reference/asciidoc/si-kafka.adoc b/src/reference/asciidoc/si-kafka.adoc index d74e980e..272bd3d6 100644 --- a/src/reference/asciidoc/si-kafka.adoc +++ b/src/reference/asciidoc/si-kafka.adoc @@ -157,7 +157,7 @@ private KafkaProducerMessageHandlerSpec kafkaMessageHandler( } ---- -If a `send-failure-channel` (`sendFailureChannel`) is provided, if a send failure is received (sync or async), an `ErrorMessage` is sent to the channel. +If a `send-failure-channel` (`sendFailureChannel`) is provided and a send failure is received (sync or async), an `ErrorMessage` is sent to the channel. The payload is a `KafkaSendFailureException` with properties `failedMessage`, `record` (the `ProducerRecord`) and `cause`. The `DefaultErrorMessageStrategy` can be overridden via the `error-message-strategy` property.