检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
Kafka实例的SSL证书有效期多长？ Kafka实例开启SASL_SSL时，需进行单向认证，证书有效期足够长（超过15年），客户端不需要关注证书过期风险。 查看SSL证书有效期的方法如下： 解压从Kafka实例控制台下载的压缩包，获取压缩包中的“phy_ca.crt”。 双击“phy_ca
单击待替换证书的实例名称，进入实例详情页面。 在“连接信息 > SSL证书”后，单击“替换”，弹出“替换SSL证书”对话框。 图2 连接信息 参考表1，设置替换SSL证书的参数。 图3 替换SSL证书 表1 替换SSL证书参数说明 参数名称 说明 Key密码 输入制作证书中设置的keystore密码
不同实例中，使用的SSL证书是否一样？ Kafka实例中的SSL证书是通用的，不区分用户或者实例，即不同的用户或者实例，使用的SSL证书是同一个。 获取SSL证书的方法如下： 在Kafka控制台，单击实例名称，进入实例详情页。 在“连接信息 > SSL证书”所在行，单击“下载”。
单击Kafka实例的名称，进入实例详情页面。 在“连接信息 > SSL证书”后，单击“下载”，将SSL证书下载到本地。 解压证书zip包，获取JKS格式的SSL证书。 登录Linux系统的服务器，将JKS格式的SSL证书上传到服务器中。 执行以下命令，将JKS格式证书转换为PKCS12格式。
配置Kafka的SSL双向认证 SSL双向认证是指在通信认证时，将同时验证客户端和服务端的证书，以确保通信中涉及的双方都是受信任的。 开启SSL双向认证，主要用于对安全性要求较高的场景。 SSL双向认证为白名单特性，需要联系后台管理人员开通后方可使用。 配置SSL双向认证的流程如图1所示。
location配置为client.jks证书的存放路径。注意，Windows系统下证书路径中也必须使用“/”，不能使用Windows系统中复制路径时的“\”，否则客户端获取证书失败。 ssl.truststore.password为服务器证书密码，不可更改，需要保持为dms@kafka。
truststore文件可以用PEM格式的吗？ 下载的证书JKS和CRT有什么区别？ Kafka支持哪个版本的TLS？ Kafka实例连接数有限制吗？ 客户端单IP连接的个数为多少？ Kafka实例的内网连接地址可以修改吗？ 不同实例中，使用的SSL证书是否一样？
如果消息组中没有在线的消费者（如empty状态），是否14天后会自动被删除？ 消息组中没有在线的消费者（如empty状态），14天后是否会自动被删除与offsets.retention.minutes、auto.create.groups.enable参数有关： 2023年4月25日前创建的实例，auto
配置Kafka访问控制 配置Kafka实例的明文/密文接入 制作和替换Kafka的SSL证书 JKS格式SSL证书转换PEM格式 配置Kafka的SSL双向认证 配置Kafka ACL用户 父主题： 连接实例
操作视频 本视频演示重置Kafka消费进度的操作。 约束与限制 重置消费进度可能会导致重复消费，请谨慎操作。 前提条件 Kafka实例不支持在线重置消费进度，请先将待重置消费进度的消费组停止消费，然后重置消费进度。停止待重置消费进度的消费者客户端后，需要等待一段时间（即ConsumerConfig
如果Kafka安全协议设置为“SASL_SSL”，在Kafka实例控制台的基本信息页面中下载证书。 使用Java语言连接实例时，需要用JKS格式的证书。使用Python语言连接实例时，需要用CRT格式的证书。
Kafka服务端支持版本是多少？ Kafka实例的ZK地址是什么？ 创建的Kafka实例是集群模式么？ Kafka实例是否支持修改访问端口？ Kafka实例的SSL证书有效期多长？ 如何将Kafka实例中的数据同步到另一个Kafka实例中？ Kafka实例的SASL_SSL开关如何修改？ SASL认证机制如何修改？
开启SASL_SSL后，实例已启用的安全协议。 开启的SASL认证机制 开启SASL_SSL后，实例已开启的SASL认证机制。 SSL证书 单击“下载”，下载连接实例的SSL证书。 内网连接地址 未开启公网访问时，连接实例的地址。 显示的连接地址个数为实例代理个数。 Manager内网访问地址
PLAINTEXT”，请注释以下参数。 context.verify_mode = ssl.CERT_REQUIRED ##证书文件，SSL证书参考“收集连接信息”章节获取。如果Kafka安全协议设置为“SASL_PLAINTEXT”，请注释以下参数。 context.load_
ic，否则会连接失败。 已下载client.jks证书。如果没有，在控制台单击Kafka实例名称，进入实例详情页面，在“连接信息 > SSL证书”所在行，单击“下载”。下载压缩包后解压，获取压缩包中的客户端证书文件：client.jks。 已下载Kafka命令行工具1.1.0版本或者Kafka命令行工具2
和AK/SK两种认证，Kerberos认证目前不支持。 如果使用SASL认证方式，则在开源客户端基础上使用分布式消息服务Kafka版提供的证书文件。具体操作参考使用客户端连接Kafka（开启SASL）。 父主题： 连接问题
启用的安全协议 在Kafka实例详情页的“连接信息”区域，获取“启用的安全协议”。 证书 在Kafka实例详情页的“连接信息”区域，在“SSL证书”所在行，单击“下载”。下载压缩包后解压，获取压缩包中的客户端证书文件：client.jks。 SASL用户名和密码 在Kafka实例控
= "username" password = "password" caFile = "phy_ca.crt" //SSL证书参考“收集连接信息”章节获取。如果Kafka安全协议设置为“SASL_PLAINTEXT”，请删除此参数。 ) func main()
location配置为client.jks证书的存放路径。注意，Windows系统下证书路径中也必须使用“/”，不能使用Windows系统中复制路径时的“\”，否则客户端获取证书失败。 ssl.truststore.password为服务器证书密码，不可更改，需要保持为dms@kafka。
algorithm参数必须设置为空，关闭域名校验开关。 ssl.endpoint.identification.algorithm= 加载SSL证书文件失败 出现下图的错误信息： 解决方案： 请检查对应地址的client.jks文件是否存在。 检查进程和文件所属权限。 检查consumer
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
