检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
CentOS环境为例，介绍Python版本的Kafka客户端连接指导，包括Kafka客户端安装，以及生产、消费消息。 使用前请参考收集连接信息收集Kafka所需的连接信息。 准备环境 Python 一般系统预装了Python，您可以在命令行输入python或者python3，查看Pyt
是否支持跨Region访问？ Kafka可以跨Region访问，但是跨Region目前只能通过公网访问或者拉专线的方式。 父主题： 连接问题
Kafka实例是否支持不同的子网？ 支持。 客户端与实例在相同VPC内，可以跨子网段访问。同一个VPC内的子网默认可以进行通信。 父主题： 连接问题
配置Kafka客户端 Kafka客户端参数配置建议 Kafka客户端使用建议 父主题： 连接实例
Kafka实例是否支持公网访问？ Kafka实例支持公网访问。使用公网访问Kafka实例的具体操作，请参考连接实例。 父主题： 连接问题
制作和替换Kafka的SSL证书 JKS格式SSL证书转换PEM格式 配置Kafka的SSL双向认证 配置Kafka ACL用户 父主题： 连接实例
Kafka实例是否支持无密码访问？ 支持，连接明文接入的Kafka实例时，无需密码。具体操作，请参考使用客户端连接Kafka（关闭SASL）。 父主题： 连接问题
入方向 TCP 9092 Kafka客户端所在的IP地址或地址组 使用对等连接跨VPC访问Kafka实例（明文接入）。 入方向 TCP 9093 Kafka客户端所在的IP地址或地址组 使用对等连接跨VPC访问Kafka实例（密文接入）。 通过公网访问实例 请按照表5设置安全组规则。
ACL用户，设置用户信息。 表1 创建用户参数说明 参数 说明 用户名 连接Kafka实例的用户名，用户名支持自定义，但需要符合命名规则：长度为4~64个字符，由英文字母开头，只能由英文字母、数字、中划线、下划线组成。 密码 连接Kafka实例的密码，密码需要符合以下规则： 长度为8~32个字符。
Kafka支持哪个版本的TLS？ Kafka支持TLS 1.2。 父主题： 连接问题
配置Kafka实例的明文/密文接入 您可以通过明文接入Kafka实例，也可以通过密文接入Kafka实例，本章节指导您在控制台修改接入方式。 明文接入：表示客户端连接Kafka实例时，无需进行SASL认证。 密文接入：表示客户端连接Kafka实例时，需要进行SASL认证。 首次修改
在Kafka控制台，单击Kafka实例名称，进入实例详情页面。在“基本信息”页签，查看公网IP地址（即“公网连接地址”）。 如果您需要连接Kafka实例，请参考连接Kafka。 父主题： 连接问题
下载的证书JKS和CRT有什么区别？ 使用Java语言连接实例时，需要用JKS格式的证书。使用Python语言连接实例时，需要用CRT格式的证书。 父主题： 连接问题
connections.max.idle.ms 600000 30000 空连接的超时时间（单位为ms），设置为30000可以在网络异常场景下减少请求卡顿的时间。 max.poll.records 500 需小于max.poll.interval.ms时间内的消费处理能力。
SSL证书的作用是在客户端和Kafka实例进行数据传输时对数据加密传输，提高了数据的安全性。 Kafka客户端连接开启密文接入且Kafka安全协议为“SASL_SSL”的Kafka实例时，您可以使用分布式消息服务Kafka版提供的证书，也可以使用自己制作的证书。如果使用自己制作的证书，请参考本章节将分布式消息服务Kafka版提供的证书替换为自己的证书。
Kafka支持服务端认证客户端吗？ 不支持。 父主题： 连接问题
Kafka-go kafka-go是一个简单、轻量级的Kafka客户端库，易于学习和使用。 kafka-go的代码库相对较小，依赖较少，可以减少应用程序的体积和依赖关系。 Kafka-go相对于Confluent-Kafka-go来说，功能较为有限，不支持一些高级特性和复杂的配置选项。
jks”在后续步骤“开启SSL双向认证”时，用来替换“Keystore文件”。“client.truststore.jks”需要存放到客户端中，并记录存放路径，此路径用于客户端连接Kafka实例时，配置文件中“ssl.truststore.location”参数的值。 步骤二：制作服务端验证客户端的证书 登录Linu
5760字节。 其他建议 连接数限制：3000 消息大小：不能超过10MB 使用SASL_SSL协议访问Kafka：确保DNS具有反向解析能力，或者在hosts文件配置Kafka所有节点IP和主机名映射，避免Kafka client做反向解析，阻塞连接建立。 磁盘容量申请超过业务量
的SSL证书是同一个。 获取SSL证书的方法如下： 在Kafka控制台，单击实例名称，进入实例详情页。 在“连接信息 > SSL证书”所在行，单击“下载”。 父主题： 连接问题
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
