Wie kann man verschiedene Datentypen in einem einzelnen Kafka -Thema mit Spring Cloud Stream deserialisieren? ⇐ Java

[Anonymous]

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".

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) {}
}

Aber ich möchte wissen, ob es einen Weg gibt, um dies zu erreichen.