troubleshooting

How can I provide the auth credentials for the schema registry when reading from Kafka?

Ralph Matthias Debusmann is looking for a way to provide authentication credentials for the schema registry when reading from Kafka. He has tried to include the credentials in the Kafka source creation query but encountered an error related to schema definition for JSON encoding. He also mentions that the schema format is JSONSchema.

Ra

Ralph Matthias Debusmann

Asked on Jul 31, 2023

  • Currently, only Avro and Protobuf are supported for schema registry in Kafka. JSONSchema is not supported yet.
  • To provide authentication credentials for the schema registry when reading from Kafka, you can include the schema.registry.username and schema.registry.password properties in the Kafka source creation query.
  • If you need to work with JSONSchema, you may need to wait for future updates that include support for JSONSchema in the schema registry.
  • Here is an example of how you can include the authentication credentials in the Kafka source creation query:
CREATE SOURCE uje_s
WITH (
   connector='kafka',
   topic='...',
   properties.bootstrap.server='...',
   scan.startup.mode='earliest',
   properties.sasl.mechanism='PLAIN',
   properties.security.protocol='SASL_SSL',
   properties.sasl.username='...',
   properties.sasl.password='...',
   schema.registry.username='...',
   schema.registry.password='...'
) FORMAT PLAIN ENCODE JSON (
   confluent_schema_registry='...'
);
Aug 02, 2023Edited by