application.yml

application.yml

spring:
  cloud:
    stream:
      bindings:
        topic1:
          destination: topic1
          contentType: application/json
          group: process
          binder: eventhub1
          consumer:
            maxAttempts: 3
         topic2:
          destination: topic2
          contentType: application/json
          group: process
          binder: eventhub2
          consumer:
            maxAttempts: 3
      binders:
        eventhub1:
          type: kafka
          defaultCandidate: false
          environment:
            spring:
              kafka:
                bootstrap-servers: xxx1.servicebus.windows.net:9093
                properties:
                  sasl.jaas.config: org.apache.kafka.common.security.plain.PlainLoginModule required username="$ConnectionString" password="Endpoint=sb://xxx1.servicebus.windows.net/;SharedAccessKeyName=<yourrolehere>;SharedAccessKey=<yourkeyhere>";
                  sasl.mechanism: PLAIN
                  security.protocol: SASL_SSL
        eventhub2:
          type: kafka
          defaultCandidate: false
          environment:
            spring:
              kafka:
                bootstrap-servers: xxx2.servicebus.windows.net:9093
                properties:
                  sasl.jaas.config: org.apache.kafka.common.security.plain.PlainLoginModule required username="$ConnectionString" password="Endpoint=sb://xxx2.servicebus.windows.net/;SharedAccessKeyName=<yourrolehere>;SharedAccessKey=<yourkeyhere>";
                  sasl.mechanism: PLAIN
                  security.protocol: SASL_SSL