Ich benutze Kafka Produzent, um Nachrichten zu einem anderen Kafka Thema zu veröffentlichen und es funktioniert ziemlich gut. Beispiel Vorlage unten:Spring Integration - Kafka Producer Error Channel
Unterstützt die obige Anweisung errorchannel wie in kafka Message Driven Inbound Channel Adapter unterstützt?
Ich brauchte, um die Fehlerzahl zu überprüfen, wenn mein ausgehenden Kafka-Server heruntergefahren ist und ich es nicht veröffentlichen kann.
Da jede Outbound passive Komponente ist und sie nur ihren Zweck durch den externen Aufruf erfüllen kann, ist es keine Überraschung, dass die Fehlerbehandlung ähnlich der try...catch in Java sein sollte, wenn wir Service-Methode aufrufen.
So ist ein Weg, Fehler Kanal upstream - Messaging Gateway oder Inbound-Kanal-Adapter zu haben.
Eine andere Möglichkeit ist die Verwendung ExpressionEvaluatingRequestHandlerAdvice in der request-handler-advice-chain der <int-kafka:outbound-channel-adapter>.
Denken Sie auch daran, dass Sie async = false Option verwenden sollten, um alle Fehler von Kafka-Interaktion in demselben Thread zu erhalten.