Wie kann man verschiedene Datentypen in einem einzelnen Kafka -Thema mit Spring Cloud Stream deserialisieren?
Posted: 18 May 2025, 22:40
Ich erstelle eine Spring -Karton -Anwendung mit Spring Cloud Stream mit Kafka. Ich erhalte verschiedene Datentypmeldungen auf einem einzelnen Kafka -Thema, aber die Nutzlast kann mit unterschiedlichen Typen (z. B. Kunde, Adresse usw.) mit einem Anwendungs-/JSON -Inhaltstyp sein. Nutzlast für die entsprechende Java -Klasse basierend auf dem Header "Typ".
Aber ich möchte wissen, ob es einen Weg gibt, um dies zu erreichen.
Code: Select all
Customer customer = objectMapper.readValue((byte[]) customerMessage.getPayload(), Customer.class);
Address address = objectMapper.readValue((byte[]) addressMessage.getPayload(), Address.class);
< /code>
und mit einem generischen Typ Verbraucher: < /p>
public class EventConsumer implements Consumer {
@Override
public void accept(final Message message) {}
}