Как подключить реестр конфлюентных облачных схем?

Question

Я использую управляемый Confluent кластер Kafka и службу реестра схем. Я могу управлять подключением конфлюентного облачного кластера kafka, добавляя следующие свойства в конфигурацию производителя (Scala)

security.protocol
ssl.endpoint.identification.algorithm
sasl.mechanism
sasl.jaas.config
org.apache.kafka.common.security.plain.PlainLoginModule

но не могу подключиться к реестру конфлюентных облачных схем. Реестр конфлюентной облачной схемы предоставляет ключ и секрет для доступа, но я не знаю, как настроить ключ и секрет. есть ли какой-либо параметр конфигурации для доступа к реестру конфлюентных облачных схем.

Answer 1

Добавление следующих свойств решит проблему.

import io.confluent.kafka.schemaregistry.client.SchemaRegistryClientConfig;


properties.put(SchemaRegistryClientConfig.BASIC_AUTH_CREDENTIALS_SOURCE, "USER_INFO")
properties.put(SchemaRegistryClientConfig.USER_INFO_CONFIG, <SCHEMA_REGISTRY_KEY> + ":" + <SCHEMA_REGISTRY_SECRET>)