diff --git a/openmetadata-docs/content/v1.2.0-SNAPSHOT/connectors/messaging/kafka/index.md b/openmetadata-docs/content/v1.2.0-SNAPSHOT/connectors/messaging/kafka/index.md index 9e94923c1e4..6cf166a4b8d 100644 --- a/openmetadata-docs/content/v1.2.0-SNAPSHOT/connectors/messaging/kafka/index.md +++ b/openmetadata-docs/content/v1.2.0-SNAPSHOT/connectors/messaging/kafka/index.md @@ -43,7 +43,8 @@ The ingestion of the Kafka topics' schema is done separately by configuring the - **SASL Password**: SASL password for use with the PLAIN and SASL-SCRAM mechanisms. - **SASL Mechanism**: SASL mechanism to use for authentication. - **Basic Auth User Info**: Schema Registry Client HTTP credentials in the form of `username:password`. By default, user info is extracted from the URL if present. -- **Consumer Config**: The accepted additional values for the consumer configuration can be found in the following [link](https://github.com/edenhill/librdkafka/blob/master/CONFIGURATION.md). +- **Consumer Config**: The accepted additional values for the consumer configuration can be found in the following [link](https://github.com/edenhill/librdkafka/blob/master/CONFIGURATION.md). +If you are using Confluent kafka and SSL encryption is enabled you need to add `security.protocol` as key and `SASL_SSL` as value under Consumer Config - **Schema Registry Config**: The accepted additional values for the Schema Registry configuration can be found in the following [link](https://docs.confluent.io/5.5.1/clients/confluent-kafka-python/index.html#confluent_kafka.schema_registry.SchemaRegistryClient). {% note %} diff --git a/openmetadata-docs/content/v1.2.0-SNAPSHOT/connectors/messaging/kafka/troubleshooting.md b/openmetadata-docs/content/v1.2.0-SNAPSHOT/connectors/messaging/kafka/troubleshooting.md index d46c7635f75..4be6c8a66d1 100644 --- a/openmetadata-docs/content/v1.2.0-SNAPSHOT/connectors/messaging/kafka/troubleshooting.md +++ b/openmetadata-docs/content/v1.2.0-SNAPSHOT/connectors/messaging/kafka/troubleshooting.md @@ -32,4 +32,8 @@ like this: "ssl.truststore.password": "password" schemaRegistryConfig: "basic.auth.user.info": "username:password" -``` \ No newline at end of file +``` + +## Connecting to Confluent Cloud Kafka + +If you are using Confluent kafka and SSL encryption is enabled you need to add `security.protocol` as key and `SASL_SSL` as value under Consumer Config