Ich habe einen Nicht-SCS-Produzent (App mit Spring-Kafka) versuchen, ein serialisiertes Json-Objekt zu einem Thema von einem SCS-Consumer abonniert senden.Nicht Spring Cloud Stream (SCS) -Produzent sendet JSON-Nachricht an SCS-Consumer
Die Nachricht über das Thema gestellt ist -
{ "message": "Hallo world2", "Handynummer": "111111"}
Der SCS Verbraucher die unter Konfiguration.
spring.cloud.stream.bindings.input.content-type = application/json spring.cloud.stream.bindings.input.consumer.headerMode = raw
Im Folgenden finden Sie einen Link zum Stacktrace - https://gist.github.com/ajaydivakaran/459b572140b14d581349b3eab5383f4d
Die Dokumentation besagt, dass SCS das Empfangen und Senden von Nutzdaten an Nicht-SCS-Produzenten und -Verbraucher unterstützt. Könnte mir jemand helfen, herauszufinden, was hier falsch ist?
Könnte jemand erklären, warum die Nachricht als String endet sogar obwohl ein JSONSerializer auf der Spring-Kafka-Herstellerseite angegeben ist? – Ajay
Danke - Zwei Tage versuchen, das herauszufinden. Das ist nicht wirklich intuitiv. Sie würden denken, wenn das Senden und Empfangen von rohen Inhaltstypen application/json wäre, würde es einfach funktionieren. –