如何连接融合云架构注册表



我使用的是Confluent托管的Kafka集群和Schema Registry服务。我可以管理连接融合云kafka集群,将以下属性添加到生产者配置(Scala(

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

但无法连接到融合云模式注册表。融合云模式注册表提供了访问的密钥和秘密,但我不知道如何设置密钥和秘密。是否有任何用于访问合流云架构注册表的配置设置。

添加以下属性将解决问题。

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

相关内容

  • 没有找到相关文章

最新更新