检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
kafka-python==2.0.1 Python 3.x版本：pip3 install kafka-python==2.0.1 生产消息 在客户端创建一个文件，用于存放生产消息的代码示例。 touch producer.py producer.py表示文件名，您可以自定义文件名。 执行以下命令，编辑文件。
properties .\src\main\resources 生产消息的配置信息。 client.jks .\src\main\resources SSL证书，用于SASL_SSL方式连接。 DmsConsumerTest.java .\src\test\java\com\dms\consumer
开启SASL_SSL后，实例已启用的安全协议。 开启的SASL认证机制 开启SASL_SSL后，实例已开启的SASL认证机制。 SSL证书 单击“下载”，下载连接实例的SSL证书。 内网连接地址 未开启公网访问时，连接实例的地址。 显示的连接地址个数为实例代理个数。 Manager内网访问地址
Kafka服务端支持版本是多少？ Kafka实例的ZK地址是什么？ 创建的Kafka实例是集群模式么？ Kafka实例是否支持修改访问端口？ Kafka实例的SSL证书有效期多长？ 如何将Kafka实例中的数据同步到另一个Kafka实例中？ Kafka实例的SASL_SSL开关如何修改？ SASL认证机制如何修改？
= "username" password = "password" caFile = "phy_ca.crt" //SSL证书参考“收集连接信息”章节获取。如果Kafka安全协议设置为“SASL_PLAINTEXT”，请删除此参数。 ) func main()
如果实例开启密文接入，则需要获得连接实例的用户名与密码、SASL认证机制和Kafka安全协议。Kafka安全协议设置为“SASL_SSL”时，还需要获取SSL证书。 连接实例的用户名在Kafka实例控制台的“用户管理”页面中查看，如果忘记密码，可通过重置密码重新获得。 图2 查看SASL用户名 S
security.protocol=SASL_SSL ## spring.kafka.ssl.trust-store-location为SSL证书的存放路径，如下代码以Windows系统路径格式举例，您在使用时请根据实际运行环境修改路径格式。 spring.kafka.ssl.tru
word为首次开启密文接入时填入的用户名和密码，或者创建用户时设置的用户名和密码。 SASL_SSL：如果已经设置了用户名和密码，以及SSL证书配置，请跳过此步骤，执行2。否则在Kafka客户端的“/config”目录中创建“ssl-user-config.properties”文件，在文件中增加如下内容。
algorithm参数必须设置为空，关闭域名校验开关。 ssl.endpoint.identification.algorithm= 加载SSL证书文件失败 出现下图的错误信息： 解决方案： 请检查对应地址的client.jks文件是否存在。 检查进程和文件所属权限。 检查consumer
ID。其中Array首位为leader副本，所有分区需要有同样数量的副本，副本数不能大于总broker的数量。 响应参数 无 请求示例 修改Topic分区的副本分布位置，分区1的副本分布在broker 1和broker 2，Leader副本在broker 1。 POST https://{endpoint
获取证书的方法如下：在Kafka控制台单击Kafka实例名称，进入实例详情页面，在“连接信息 > SSL证书”所在行，单击“下载”。解压压缩包，获取压缩包中的客户端证书文件：client.jks。 “/root”为证书存放路径，请根据实际情况修改。 进入Kafka客户端文件的“/config”目录下。
Kafka是否支持Kerberos认证，如何开启认证？ Kafka支持SASL客户端认证、调用接口支持Token和AK/SK两种认证，Kerberos认证目前不支持。 如果使用SASL认证方式，则在开源客户端基础上使用分布式消息服务Kafka版提供的证书文件。具体操作参考使用客户端连接Kafka（开启SASL）。
word为首次开启密文接入时填入的用户名和密码，或者创建用户时设置的用户名和密码。 SASL_SSL：如果已经设置了用户名和密码，以及SSL证书配置，请跳过此步骤，执行2。否则在Kafka客户端的“/config”目录中创建“ssl-user-config.properties”文件，在文件中增加如下内容。
ic，否则会连接失败。 已下载client.jks证书。如果没有，在控制台单击Kafka实例名称，进入实例详情页面，在“连接信息 > SSL证书”所在行，单击“下载”。下载压缩包后解压，获取压缩包中的客户端证书文件：client.jks。 已下载Kafka命令行工具1.1.0版本或者Kafka命令行工具2
word为首次开启密文接入时填入的用户名和密码，或者创建用户时设置的用户名和密码。 SASL_SSL：如果已经设置了用户名和密码，以及SSL证书配置，请跳过此步骤，执行2。否则在Kafka客户端的“/config”目录中创建“ssl-user-config.properties”文件，在文件中增加如下内容。
#安全协议为“SASL_SSL”时，配置信息如下。 security.protocol=SASL_SSL #ssl truststore.location为SSL证书的存放路径，如下代码以Windows系统路径格式举例，您在使用时请根据实际运行环境修改路径格式。 ssl.truststore.locat
word为首次开启密文接入时填入的用户名和密码，或者创建用户时设置的用户名和密码。 SASL_SSL：如果已经设置了用户名和密码，以及SSL证书配置，请跳过此步骤，执行2。否则在Kafka客户端的“/config”目录中创建“ssl-user-config.properties”文件，在文件中增加如下内容。
Kafka实例的ZK地址是什么 Kafka实例的SASL_SSL开关如何修改？ Kafka实例是否支持修改访问端口？ Kafka实例的SSL证书有效期多长？ 更多 Topic与分区 为什么限制Topic的总分区数？ 为什么不支持减少分区数？ 是否支持自动生成Topic功能？ 删除Topic不生效是什么原因？
重置密码 功能介绍 重置密码（只针对开通SSL的实例）。 调用方法 请参见如何调用API。 URI POST /v2/{project_id}/instances/{instance_id}/password 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是
word为首次开启密文接入时填入的用户名和密码，或者创建用户时设置的用户名和密码。 SASL_SSL：如果已经设置了用户名和密码，以及SSL证书配置，请跳过此步骤，执行2。否则在Kafka客户端的“/config”目录中创建“ssl-user-config.properties”文件，在文件中增加如下内容。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
