Spring Cloud Stream Kafka Binder enableDlq не работает так, как я ожидал

Я использую связыватель kafka spring-cloud-stream с реестром схем (не потоки kakfa). Я пытаюсь сделать, когда недесериализуемое сообщение попало во входную тему, отправить недесериализуемое сообщение в dlq.

Итак, я попробовал, как показано ниже, но приложение Spring Cloud Stream продолжает повторять попытки бесконечно и сообщает

Вызвано: org.apache.kafka.common.errors.SerializationException: ошибка десериализации сообщения Avro для идентификатора -1

spring.cloud.stream:
  function:
    definition: functionName
  bindings:
    functionName-in-0:
      group: group-name
      destination: input-topic
  kafka:
    binder:
      brokers: localhost:9092
    bindings:
      functionName-in-0:
        consumer:
          enableDlq: true
          dlqName: input-topic-dlq
          autoCommitOnError: true
          autoCommitOffset: true
    default:
      consumer:
        configuration:
          schema.registry.url: http://localhost:8081
          key.deserializer: org.apache.kafka.common.serialization.StringDeserializer
          value.deserializer: io.confluent.kafka.serializers.KafkaAvroDeserializer

Что я делаю неправильно? Пожалуйста помоги.