Spring云流生产者重试和错误处理

Question

我设置了一个Spring云流Kafka制作人和消费者，有3个Kafka经纪人在运行。我已经设置了min.insync。将副本复制到4，以查看生产者错误处理的工作方式。消息通道。send（发送）

server.port: 9050
spring:
  cloud:
    stream:
      bindings:
        errorChannel:
          destination: error-topic
        output:
          destination: stream-topic
          group: top-group
          producer:
            errorChannelEnabled: true
      kafka:
        bindings:
          output:
            producer:
              retries: 3
              sync: false
        binder:
          autoCreateTopics: true
          configuration:
            value:
              serializer: com.example.kafkapublisher.MySerializer
          producer-properties:
            acks: all
spring.cloud.stream.kafka.bindings.errorChannel.consumer.enableDlq: true
  

以上是我的生产者配置。虽然retries设置为3，但生产者仍会多次重试。虽然sync设置为true，但发送呼叫会立即发出。虽然定义了错误通道和目标，并且将errorChannelEnabled设置为true，但我在错误主题my error中没有看到失败的消息，也没有创建错误主题。请求您的帮助

Answer 1

Kafka制作人的任意属性出现在。。。制作人配置属性。

https://docs.spring.io/spring-cloud-stream/docs/current/reference/html/spring-cloud-stream-binder-kafka.html#kafka-生产者财产

配置

使用包含通用Kafka生产者属性的键/值对映射。此处无法设置bootstrap.servers属性；如果需要连接到多个集群，请使用多绑定器支持。

默认值：空地图。