So konfigurieren Sie den Spring Cloud Stream (Kafka) für die Verwendung von Protobuf als Serialisierung

Question

Ich verwende Spring Cloud Stream (Kafka), um Nachrichten zwischen Producer und Consumer Microservices auszutauschen. Es tauscht Daten mit nativer Java-Serialisierung aus. Laut Dokumentation der Spring Cloud unterstützt es JSON, AVRO Serialisierung.

Ist irgendeine protobuf Serialisierung (Nachrichtenumformer) im Frühjahr Wolke Strom

versuchte ---------------- später hinzugefügt

ich diesen MessageConverter schrieb

Answer 1

Es ist wirklich keine Frage des Versuchs, sondern es nur zu tun, da Konverter ein natürlicher Erweiterungsmechanismus (geerbt von Federintegration) im Frühling-Wolke-Strom sind, der spezifisch existiert, um diesen Bedenken zu begegnen. Also ja, Sie können Ihren eigenen benutzerdefinierten Konverter hinzufügen.

Denken Sie auch daran, dass es bei Kafka auch ein Konzept für native Serde gibt, also müssen Sie sicherstellen, dass die beiden keinen Konflikt erzeugen.