application.yml

server:
  port: 8086

spring:
  cloud:
    stream:
      kafka:
        binder:
          auto-create-topics: true
          brokers: localhost:9092 
#          localhost:19092,localhost:29092,localhost:39092
          transaction:
            producer:
              error-channel-enabled: true
              sync: true
          producerProperties:
            acks: all
            retry.backoff.ms: 200
            linger.ms: 100
            max.in.flight.requests.per.connection: 1
            enable.idempotence: true
            retries: 3
            compression.type: snappy
            request.timeout.ms: 5000
            key.serializer: org.apache.kafka.common.serialization.StringSerializer
          consumer-properties:
            session.timeout.ms: 20000
            max.poll.interval.ms: 350000
            enable.auto.commit: true
            allow.auto.create.topics: true
            auto.commit.interval.ms: 12000
            max.poll.records: 5
            isolation.level: read_committed
          configuration:
            auto.offset.reset: latest
        bindings:
          test-input:
            consumer:
              startOffset: latest
              autoCommitOnError: true
              queueBufferingMaxMessages: 100000
              autoCommitOffset: true
          test-output:
             producer:
               configuration:
                 acks: all
               sync: true

      bindings:

        test-input:
          # contentType: text/plain
          destination: test.produce
          group: test-kafka-consumer-2
          consumer:
            maxAttempts: 3


        test-output:
          # contentType: text/plain
          destination: test.produce.another
          group: test-produce-out