相关疑难解决方法(0)

我有一个 Spring Boot 应用程序，它定义了：

• 写入 kafka 主题 STREAM_TOPIC_IN_QQQ 的 REST 控制器
• 从 STREAM_TOPIC_IN_QQQ (groupId="bar") 和日志读取的 KafkaListener
• 一个查看主题并记录它的 KStream，将其转换为另一种类型，然后将其写入 STREAM_TOPIC_OUT_QQQ
• 另一个从 STREAM_TOPIC_OUT_QQQ 读取的 KafkaListener。

（我已经改变了后缀，以避免任何可能的混乱，手工创建的主题，否则我得到一个警告，STREAM_TOPIC_IN_ XXX = LEADER_NOT_AVAILABLE和流不会为一分钟左右运行。）

第一个侦听器和流似乎正在工作，但是当 STREAM_OUT_TOPIC 上的侦听器尝试反序列化消息时，我收到以下异常。我正在使用 Produced.with 提供流中的 serde。我需要做什么才能让侦听器知道要反序列化的类型？

日志

11 Mar 2019 14:34:00,194   DEBUG    [KafkaMessageController [] http-nio-8080-exec-1]   Sending a Kafka Message
11 Mar 2019 14:34:00,236   INFO     [KafkaConfig [] kafka9000-v0.1-b0a60795-0258-48d9-8c87-30fa9a97d7b8-StreamThread-1]   -------------- STREAM_IN_TOPIC peek: Got a greeting in the stream: Hello, World!
11 Mar 2019 14:34:00,241   INFO     [KafkaConfig [] org.springframework.kafka.KafkaListenerEndpointContainer#1-0-C-1]   STREAM_IN_TOPIC Listener: ConsumerRecord: {}ConsumerRecord(topic = STREAM_TOPIC_IN_QQQ, partition …