Как подключить реестр облачной схемы? - PullRequest
Новая
       42

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

0 голосов
/ 05 апреля 2020

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

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

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

1 Ответ

0 голосов
/ 06 апреля 2020

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

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>)
...