Spring Cloud Stream Kafka绑定器无法使用密钥发布到DLQ

spring:
  cloud:
    stream:
      bindings:
        output:
          destination: my-topic
          binder: kafka
      binders:
        kafka:
          type: kafka
          environment:
            spring:
              cloud:
                stream:
                  kafka:
                    binder:
                      brokers: localhost:9092
                      configuration:
                        key.serializer: org.apache.kafka.common.serialization.StringSerializer
                        value.serializer: org.apache.kafka.common.serialization.StringSerializer
      kafka:
        bindings:
          output:
            producer:
              use-native-encoding: true
              auto-retry-enabled: true
              retry-template:
                back-off-initial-interval: 1000
                back-off-max-interval: 10000
                back-off-multiplier: 2.0
              error-handler:
                type: dead-letter-queue
                dead-letter-queue-topic: my-dlq-topic

kafka-acls --authorizer-properties zookeeper.connect=localhost:2181 \
  --add --allow-principal User:producer-user \
  --operation Read --operation Write \
  --topic my-topic

<dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-stream-binder-kafka</artifactId>
  <version>最新版本</version>
</dependency>

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.messaging.Source;
import org.springframework.messaging.support.MessageBuilder;

@EnableBinding(Source.class)
public class KafkaProducer {

    private final Source source;

    public KafkaProducer(Source source) {
        this.source = source;
    }

    public void sendMessage(String message, String key) {
        source.output().send(MessageBuilder.withPayload(message).setHeader("key", key).build());
    }
}