Spring integration kafka how to handle error when produce to kafka - Stack Overflow

Spring integration kafka how to handle error when produce to kafka - Stack Overflow

While using int-kafka:outbound-channel-adapter to produce to kafka, there seems no error-channel available. In this case how to handle message failed to produce to kafka after reties times?

Any error that could cause produce to kafka failure. (Following code just code snippet from internet, just wondering how to add error handle to it)

Read full article from Spring integration kafka how to handle error when produce to kafka - Stack Overflow