我有一个简单的Spring Cloud Stream项目，该项目使用Spring Integration DSL流程并使用Kafka活页夹。一切正常，但是来自Kafka的消息标头值到达为byte[]。
这意味着我的SI @Header参数必须为byte[]类型。哪个可行，但最好将它们作为字符串使用（我关心的所有入站标头都是字符串值）。
我已配置Kafka客户端以使用StringSerializer / StringDeserializer。我认为我还需要以某种方式告诉Spring Kafka哪些标题映射为String，以及要使用的字符编码。
我显然在这里丢失了一些东西。有提示吗？
我有一个简单的Spring Cloud Stream项目，该项目使用Spring Integration DSL流程并使用Kafka活页夹。一切正常，但是来自Kafka的消息头值以byte []的形式到达。这个...
将活页夹属性headerMapperBeanName设置为DefaultKafkaHeaderMapper bean的bean名称。