0
Wir verwenden Java-Konfiguration für Hersteller asynchronen Wiederholungsmechanismus SeiteKafka serialisiert-deserialize Ausgabe
und auf den Verbraucher zu erreichen, verwenden wir Nachricht angetrieben Adapter (xml-Konfiguration).
erkennen, dass in der Produzentenseite wir
props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,MessageSerializer.class.getName());
auf Produzent, haben wir nicht haben Option zur Einstellung der Encoder Implementierung, da es nur die Serializer Interface-Implementierung unterstützen
MessageSerializer Arbeitsgeräte Serializer
und auf der Verbraucher Seite haben wir nicht deserialize Option, da es nur Decoder Interface-Implementierung unterstützen:
<int-kafka:message-driven-channel-adapter
id="inAdapter"
channel="fromKafka"
connection-factory="connectionFactory"
key-decoder="kafkaKeyDecoder"
payload-decoder="kafkaDecoder"
topics="${topic.list}"
offset-manager="offsetManager"/>
kafkaDecoder implementiert Decoder
Therfore immer Fehler bei der Serialisierung, können Sie vorschlagen, bitte, wie man geh damit um.