mirror of
https://github.com/open-metadata/OpenMetadata.git
synced 2025-07-08 01:29:37 +00:00
1.7 KiB
1.7 KiB
title | slug |
---|---|
Kafka Connector Troubleshooting | /connectors/messaging/kafka/troubleshooting |
Troubleshooting
{% partial file="/v1.8/connectors/troubleshooting.md" /%}
Consumer and schema registry config
When configuring the Kafka connector, we could need to pass extra parameters to the consumer or the schema registry to be able to connect. The accepted values for the consumer can be found in the following link, while the ones optional for the schema registry are here.
If you encounter issues connecting to the Schema Registry, ensure that the protocol is explicitly specified in the Schema Registry URL. For example:
- Use
http://localhost:8081
instead oflocalhost:8081
. The Schema Registry requires a properly formatted URL, including the protocol (http://
orhttps://
). While this differentiation is expected in the Schema Registry configuration, it may not be immediately apparent.
In case you are performing the ingestion through the CLI with a YAML file, the service connection config should look like this:
serviceConnection:
config:
type: Kafka
bootstrapServers: localhost:9092
schemaRegistryURL: http://localhost:8081
schemaRegistryTopicSuffixName: "suffix-name"
consumerConfig:
"ssl.truststore.password": "password"
schemaRegistryConfig:
"basic.auth.user.info": "username:password"
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