我將來自 Kafka 主題的消息存儲在 KeyValueStore 中，以便稍后查詢它們。我創(chuàng)建一個 KTable 如下：@StreamListener    public void process(@Input("input") KTable<String,MyMessage> myMessages) {我在 application.yml 中配置了消費者，如下所示：更新的反/序列化程序包spring.cloud.stream.kafka.streams.bindings.input:  consumer:    materializedAs: all-messages    key-deserializer: org.apache.kafka.common.serialization.StringDeserializer    value-deserializer: com.me.MyMessageDeserializer    key-serializer: org.apache.kafka.common.serialization.StringSerializer    value-serializer: com.me.MyMessageSerializer但是，當我從 KeyValueStore 中讀取時，鍵作為字符串正確返回，但返回的值是字節(jié)數(shù)組而不是 MyMessage。出于某種原因，我的自定義解串器沒有被使用。我試圖自己反序列化消息，但我的反序列化器因異常而崩潰。我在我的序列化器上放置了一個斷點，但它從未被調用過。我很清楚我的序列化器或反序列化器都沒有被使用。我缺少什么配置以便使用我的自定義值反序列化器？反序列化器是否需要在特定的包中才能找到？