with spring cloud stream binding to pulsar the dead letter policy doesn't apply to the consumer

108 Views Asked by At

I am using spring cloud stream bindings to consume pulsar messages with. implementation("org.springframework.pulsar:spring-pulsar-spring-cloud-stream-binder:0.1.1-SNAPSHOT") this library is used. Following is the application.yaml configuration.

# pulsar
  pulsar:
    client:
      service-url: pulsar://localhost:6650
  cloud:
    function:
      definition: notificationListener
    stream:
      bindings:
        notificationListener-in-0:
          destination: notification
          consumer:
            use-native-decoding: true

      pulsar:
        bindings:
          notificationListener-in-0:
            consumer:
              negative-ack-redelivery-delay: 1s
              dead-letter-policy:
                dead-letter-topic: notification-dlq
                max-redeliver-count: 5
              schema-type: JSON
              message-type: global.din.notification.data.dto.BrokerMessage

but the given dead-letter-policy doesn't apply to the topic and consumer.

0

There are 0 best solutions below