如何在 Kafka Streams 中为不同的处理器使用不同的 serdes？
How to use different serdes for different processors in Kafka Streams?
我有一个拓扑，其中有 2 个不同的源主题（2 个子拓扑）。
其中一个是 Avro 格式，另一个是 JSON。
有没有办法为不同的处理器使用不同的 Serdes？
我已经看到商店有 Consumed.with() 但我没有看到处理器有任何这样的东西。
除了编写自己的序列化程序或反序列化程序来区分主题和 serializes/deserializes 之外，是否有使用不同 serdes 的配置？
拓扑 class 包含具有 Serializer 和 Deserializer
的 addSource 方法
Topology addSource(String sourceName, Deserializer keyDeserializer, Deserializer valueDeserializer, String... topics)
我有一个拓扑，其中有 2 个不同的源主题（2 个子拓扑）。
其中一个是 Avro 格式，另一个是 JSON。
有没有办法为不同的处理器使用不同的 Serdes？
我已经看到商店有 Consumed.with() 但我没有看到处理器有任何这样的东西。
除了编写自己的序列化程序或反序列化程序来区分主题和 serializes/deserializes 之外，是否有使用不同 serdes 的配置？
拓扑 class 包含具有 Serializer 和 Deserializer
addSource 方法
Topology addSource(String sourceName, Deserializer keyDeserializer, Deserializer valueDeserializer, String... topics)