BenthOS AzureEventHub Source

benthos_eh_to_kafka_conf.yaml

input:
  kafka:
    addresses:
      - ${EVENTHUB_BOOTSTRAP_SERVER}
    topics: [${EVENTHUB_TOPIC}]
    tls:
      enabled: true
      skip_cert_verify: true
      root_cas_file: ""
      client_certs: []
    sasl:
      mechanism: "PLAIN"
      user: "$ConnectionString"
      password: "${EVENTHUB_CONNECTION_STRING}"
      access_token: ""
      token_cache: ""
      token_key: ""
    consumer_group: ${EVENTHUB_CLIENT_ID}
    client_id: ${EVENTHUB_CLIENT_ID}
    start_from_oldest: true
    checkpoint_limit: 1
    commit_period: 1s
    max_processing_period: 100ms
    group:
      session_timeout: 10s
      heartbeat_interval: 3s
      rebalance_timeout: 60s
    fetch_buffer_cap: 256
    target_version: 1.0.0

output:
  kafka:
    addresses:
    - ${KAFKA_BOOTSTRAP_SERVER}
    topic: ${KAFKA_TOPIC}
    round_robin_partitions: true
    tls:
      enabled: true
      root_cas_file: ${KAFKA_CERTIFICATE_LOCATION}/ca.pem
      client_certs:
        - cert_file: ${KAFKA_CERTIFICATE_LOCATION}/service.cert
          key_file: ${KAFKA_CERTIFICATE_LOCATION}/service.key

BenthOS Azure Eventhub(Kafka Enabled) source to Kafka sink.