Spring Cloud Stream:所有绑定的默认死信队列

spring:
  cloud:
    stream:
      bindings:
        input:
          destination: your-input-topic
          group: your-input-group
          binder: your-binder
          consumer:
            max-attempts: 3
            back-off-initial-interval: 1000
            back-off-max-interval: 10000
            back-off-multiplier: 2.0
        output:
          destination: your-output-topic
          binder: your-binder
      binders:
        your-binder:
          type: kafka
          environment:
            spring:
              cloud:
                stream:
                  kafka:
                    binder:
                      brokers: localhost:9092
      default-retryable: true
      bindings:
        input:
          consumer:
            use-native-decoding: true
        output:
          producer:
            use-native-encoding: true

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

public interface DLQBinding {
    String INPUT = "dlqInput";
    String OUTPUT = "dlqOutput";

    @Input(INPUT)
    SubscribableChannel dlqInput();

    @Output(OUTPUT)
    MessageChannel dlqOutput();
}

spring:
  cloud:
    stream:
      bindings:
        dlqInput:
          destination: your-dlq-topic
        dlqOutput:
          destination: your-dl齐topic