为了管理在Kafka绑定器中生成/消费的消息的头，有一个KafkaHeaderMapper接口，其作为bean的实现可以配置以下属性：spring.cloud.stream.kafka.binder.headerMapperBeanName。
Spring Cloud Stream中的KafkaStreams绑定器有类似的东西吗？我的意图是能够控制如何在流输入和输出上反序列化/序列化或包含/排除消息头。有人知道如何实现这一点吗？
没有等价物；对于流；Spring只参与设置基础设施/拓扑结构；它不涉及运行时记录处理。
但是，您可以使用自定义序列化程序/反序列化程序并在那里操作头。