小编Ann*_*nnu的帖子

我计划使用 Spring Kafka 客户端从 Spring Boot 应用程序中的 kafka 设置中使用和生成消息。我在 Kafka 0.11 中看到了对自定义标头的支持，详见此处。虽然它可用于本地 Kafka 生产者和消费者，但我看不到在 Spring Kafka 中添加/读取自定义标头的支持。

我正在尝试基于重试计数为消息实现 DLQ，我希望将其存储在消息标头中，而无需解析有效负载。