测试失败的示例项目位于https://github.com/phillipuniverse/kafka-headers-test。
让我感到奇怪的是，Spring Integration 中的 ID 和 TIMESTAMP 标头已被删除，因为它们不能在收到消息时使用。这是一个错误吗？
我遇到了一个相关问题here，其中提到了这些标头是瞬态的，这让我认为这种行为是故意的。为什么它们是短暂的？为什么这些不像其他所有正确映射的自定义标头一样？特殊待遇有什么特殊原因吗？
【问题讨论】：
标签： spring-boot spring-integration spring-kafka spring-cloud-stream
这样做是出于性能原因，其中 id 和时间戳的生成可能会影响某些高容量情况下的性能。
您可以使用 standardHeaders consumer property 更改行为：
标准标头
指示入站通道适配器填充哪些标准标头。允许的值：
none、id、timestamp或both。如果使用本机反序列化并且接收消息的第一个组件需要一个 id（例如配置为使用 JDBC 消息存储的聚合器），则很有用。默认：无
【讨论】：
spring.cloud.stream.kafka.default.standard-headers=both 会导致它们被映射。这是你期望发生的事情吗？
KafkaExtendedBindingProperties，其中consumer 需要设置standardHeaders。这个完整的属性是有效的：spring.cloud.stream.kafka.default.consumer.standard-headers=both