我使用的是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>)