diff --git a/metadata-ingestion/README.md b/metadata-ingestion/README.md index 8210533c85f1e3..43143c497503bf 100644 --- a/metadata-ingestion/README.md +++ b/metadata-ingestion/README.md @@ -152,11 +152,13 @@ source: config: connection: bootstrap: "broker:9092" - consumer_config: {} # passed to https://docs.confluent.io/platform/current/clients/confluent-kafka-python/html/index.html#serde-consumer + consumer_config: {} # passed to https://docs.confluent.io/platform/current/clients/confluent-kafka-python/html/index.html#confluent_kafka.DeserializingConsumer schema_registry_url: http://localhost:8081 schema_registry_config: {} # passed to https://docs.confluent.io/platform/current/clients/confluent-kafka-python/html/index.html#confluent_kafka.schema_registry.SchemaRegistryClient ``` +The options in the consumer config and schema registry config are passed to the Kafka DeserializingConsumer and SchemaRegistryClient respectively. + For a full example with a number of security options, see this [example recipe](./examples/recipes/secured_kafka.yml). ### MySQL Metadata `mysql` @@ -895,11 +897,13 @@ sink: config: connection: bootstrap: "localhost:9092" - producer_config: {} # passed to https://docs.confluent.io/platform/current/clients/confluent-kafka-python/html/index.html#serializingproducer + producer_config: {} # passed to https://docs.confluent.io/platform/current/clients/confluent-kafka-python/html/index.html#confluent_kafka.SerializingProducer schema_registry_url: "http://localhost:8081" schema_registry_config: {} # passed to https://docs.confluent.io/platform/current/clients/confluent-kafka-python/html/index.html#confluent_kafka.schema_registry.SchemaRegistryClient ``` +The options in the producer config and schema registry config are passed to the Kafka SerializingProducer and SchemaRegistryClient respectively. + For a full example with a number of security options, see this [example recipe](./examples/recipes/secured_kafka.yml). ### Console `console`