21 lines
448 B
YAML

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"