run_id: kafka-test

source:
  type: kafka
  config:
    connection:
      bootstrap: "localhost:29092"
      schema_registry_url: "http://localhost:28081"
      consumer_config:
        security.protocol: "SASL_PLAINTEXT"
        sasl.mechanism: "OAUTHBEARER"
        oauth_cb: "oauth:create_token"
    domain:
      "urn:li:domain:sales":
        allow:
          - "key_value_topic"
sink:
  type: file
  config:
    filename: "./kafka_mces.json"