Как использовать разные serdes для разных процессоров в Kafka Streams?

Question

У меня есть топология, в которой у меня есть 2 различных исходных темы (2 под-топологии). Один из них в формате Avro, а другой - JSON. Есть ли способ использовать разные Serdes для разных процессоров? Я видел, что для магазина есть Consumed.with(), но я не вижу ничего подобного для процессоров.

Кроме написания моего собственного сериализатора или десериализатора, который различает темы и соответственно сериализует / десериализует , есть ли конфигурация для использования разных серий?

Answer 1

Класс Topology содержит метод addSource с Serializer и Deserializer

Topology addSource(String sourceName, Deserializer keyDeserializer, Deserializer valueDeserializer, String... topics)