application.yml

spring:
  cloud:
    stream:
      poller:
        fixedDelay: 100
        max-messages-per-poll: 100
      default:
        content-type: application/*+avro
        producer:
          partitionCount: 1
          use-native-encoding: true
        consumer:
          use-native-decoding: true

      function:
        definition: >
          cartEventsConsumer;
          paymentEventsConsumer;
          shippingEventsConsumer;
          orderEventsSupplier;
      bindings:
        cartEventsConsumer-in-0:
          destination: cart-events
          group: orders-cartConsumer
        paymentEventsConsumer-in-0:
          destination: payment-events
          group: orders-paymentConsumer
        shippingEventsConsumer-in-0:
          destination: shipping-events
          group: orders-shippingConsumer
        orderEventsSupplier-out-0:
          destination: order-events

      kafka:
        default:
          consumer:
            ack-mode: manual
            enable-dlq: true