|
This version is still in development and is not considered stable yet. For the latest stable version, please use spring-cloud-stream 4.1.4! |
Error Channels
Starting with version 1.3, the binder unconditionally sends exceptions to an error channel for each consumer destination and can also be configured to send async producer send failures to an error channel. See this section on error handling for more information.
The payload of the ErrorMessage for a send failure is a KafkaSendFailureException with properties:
-
failedMessage: The Spring MessagingMessage<?>that failed to be sent. -
record: The rawProducerRecordthat was created from thefailedMessage
There is no automatic handling of producer exceptions (such as sending to a dead letter topic). You can consume these exceptions with your own Spring Integration flow.
