检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
afka实例。 创建Kafka实例时，支持开启或者关闭SASL_SSL。开源Kafka客户端连接开启SASL_SSL的Kafka实例，与连接未开启SASL_SSL的Kafka实例的端口号不同，且开启SASL_SSL的Kafka实例需要配置证书信息。 支持区域： 全部 连接未开启SASL的Kafka实例
Topic是否支持ACL权限配置？ Kafka实例已开启Kafka SASL_SSL功能，此时Topic支持配置ACL权限。在Kafka控制台的“Topic管理”页面，在需要设置用户权限的Topic所在行，单击“设置用户权限”，为用户设置不同的权限。 具体操作请参考设置Topic权限。
'sasl_password': 'password' } context = ssl.create_default_context() context = ssl.SSLContext(ssl.PROTOCOL_SSLv23) ##如果Kafka安全协议设置为“SASL_PLAINTEXT”，请注释以下参数。
properties和producer.properties文件，ssl.endpoint.identification.algorithm参数必须设置为空，关闭域名校验开关。 ssl.endpoint.identification.algorithm= 加载SSL证书文件失败 出现下图的错误信息： 解决方案：
protocol为安全协议。 ## 安全协议为“SASL_SSL”时，配置信息如下。 spring.kafka.security.protocol=SASL_SSL ## spring.kafka.ssl.trust-store-location为SSL证书的存放路径，如下代码以Windows系
SASL_SSL：如果已经设置了用户名和密码，以及SSL证书配置，请跳过此步骤，执行2。否则在Kafka客户端的“/config”目录中创建“ssl-user-config.properties”文件，在文件中增加如下内容。 security.protocol=SASL_SSL ssl
如果实例开启密文接入，则需要获得连接实例的用户名与密码、SASL认证机制和Kafka安全协议。Kafka安全协议设置为“SASL_SSL”时，还需要获取SSL证书。 连接实例的用户名在Kafka实例控制台的“用户管理”页面中查看，如果忘记密码，可通过重置密码重新获得。 图2 查看SASL用户名
SASL_SSL”，需要设置此参数。 security.protocol：Kafka的安全协议。在Kafka实例控制台的基本信息页面中获取。很久前创建的Kafka实例在详情页如果未显示“启用的安全协议”，默认使用SASL_SSL协议。 安全协议设置为“SASL_SSL”时，采用S
如果消息组中没有在线的消费者（如empty状态），是否14天后会自动被删除？ 消息组中没有在线的消费者（如empty状态），14天后是否会自动被删除与offsets.retention.minutes、auto.create.groups.enable参数有关： 2023年4月25日前创建的实例，auto
\src\main\resources 生产消息的配置信息。 client.jks .\src\main\resources SSL证书，用于SASL_SSL方式连接。 DmsConsumerTest.java .\src\test\java\com\dms\consumer 消费消息的测试代码。
SASL_SSL：如果已经设置了用户名和密码，以及SSL证书配置，请跳过此步骤，执行2。否则在Kafka客户端的“/config”目录中创建“ssl-user-config.properties”文件，在文件中增加如下内容。 security.protocol=SASL_SSL ssl
SASL_SSL：如果已经设置了用户名和密码，以及SSL证书配置，请跳过此步骤，执行2。否则在Kafka客户端的“/config”目录中创建“ssl-user-config.properties”文件，在文件中增加如下内容。 security.protocol=SASL_SSL ssl
查看Java、Go和Python生产消费消息的示例代码。示例代码区分是否开启SASL_SSL认证，“接入类型”为“PlainText”时，表示未开启SASL_SSL认证。“接入类型”为“SASL_SSL”时，表示已开启SASL_SSL认证。 父主题： 管理实例
如何修改安全协议？ Kafka实例的安全协议包括SASL_SSL和SASL_PLAINTEXT。 未开启IPv6的实例，仅部分Region支持修改安全协议，具体以控制台为准。先在Kafka实例的详情页的“连接信息”区域，关闭密文接入，然后再开启密文接入，此时可以重新设置安全协议。
#安全协议为“SASL_SSL”时，配置信息如下。 security.protocol=SASL_SSL #ssl truststore.location为SSL证书的存放路径，如下代码以Windows系统路径格式举例，您在使用时请根据实际运行环境修改路径格式。 ssl.truststore
在实例列表页面，查看变更是否成功？ 实例状态从“变更中”变为“运行中”时，表示变更成功，在“规格”中查看扩容后的带宽大小。 图3 查看扩容后的带宽 实例状态从“变更中”变为“变更失败”时，表示变更失败，把鼠标放在“变更失败”上，显示变更失败的原因。 实例状态为“变更失败”时，无法对实
创建的Kafka实例是集群模式么？ Kafka实例是否支持修改访问端口？ Kafka实例的SSL证书有效期多长？ 如何将Kafka实例中的数据同步到另一个Kafka实例中？ Kafka实例的SASL_SSL开关如何修改？ SASL认证机制如何修改？ 如何修改安全协议？ 修改企业项目，是否会导致Kafka重启？
SASL_SSL：如果已经设置了用户名和密码，以及SSL证书配置，请跳过此步骤，执行2。否则在Kafka客户端的“/config”目录中创建“ssl-user-config.properties”文件，在文件中增加如下内容。 security.protocol=SASL_SSL ssl
private_sasl_ssl_enable Boolean 是否开启内网SASL_SSL开关 private_sasl_ssl_address String 内网SASL_SSL连接地址 private_sasl_ssl_domain_name String 内网SASL_SSL连接域名 p
连接未开启SASL的Kafka实例 分布式消息服务Kafka版 介绍怎样连接开启SASL_SSL的Kafka实例 06:16 连接开启SASL_SSL的Kafka实例 分布式消息服务Kafka版 介绍怎样扩容Kafka实例 04:46 变更实例规格 分布式消息服务Kafka版 介绍怎样删除消费组 03:08
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
