检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
入方向 TCP IPv4 9093 Kafka客户端所在的IP地址或地址组 使用内网通过同一个VPC访问Kafka实例（开启SSL加密）。
访问Kafka Manager Kafka Manager是开源的Kafka集群管理工具，需要通过浏览器才能访问Kafka Manager的地址。在Kafka Manager页面，您可以查看Kafka集群的监控、代理等信息。
连接安全协议为“SASL_SSL”的Kafka实例时，使用SASL认证，数据通过SSL证书进行加密传输，安全性更高。 创建Topic Topic用于存储消息，供生产者生产消息以及消费者订阅消息。 本文以在控制台创建Topic为例介绍。
入方向 TCP IPv6 9193 Kafka客户端所在的IP地址或地址组 通过IPv6地址访问Kafka实例（开启SSL加密）（内网和公网都适用）。
Kafka集群实例 Kafka集群实例规格 Kafka集群实例由三个及以上代理组成，兼容开源Kafka 1.1.0、2.7和3.x。 TPS（Transaction per second），在Kafka场景中，指每秒能写入到Kafka实例的最大消息数量。
disk_encrypted Boolean 是否开启磁盘加密。 disk_encrypted_key String 磁盘加密key，未开启磁盘加密时为空。 kafka_private_connect_address String Kafka实例内网连接地址。
使用客户端连接Kafka（关闭SASL） 本章节介绍如何使用开源的Kafka客户端访问关闭SASL的Kafka实例的方法。关闭SASL表示客户端访问Kafka实例时，无需进行认证，数据通过明文传输，性能更好。
Kafka业务使用流程 分布式消息服务Kafka版是一款基于开源社区版Kafka提供的消息队列服务，向用户提供计算、存储和带宽资源独占式的Kafka实例。使用Kafka实例生产消费消息的流程如下图所示。
安全协议设置为“SASL_SSL”时，采用SASL方式进行认证，数据通过SSL证书进行加密传输，安全性更高。此时需要配置连接实例的用户名和密码，以及证书文件。 安全协议设置为“SASL_PLAINTEXT”时，采用SASL方式进行认证，数据通过明文传输，性能更好。
下载Kafka 3.3.1版本的二进制软件包。 wget https://archive.apache.org/dist/kafka/3.3.1/kafka_2.12-3.3.1.tgz 解压二进制软件包。
在该日期之后，不再提供该软件版本的任何技术服务支持。 父主题： 版本公告
安全协议设置为“SASL_SSL”时，采用SASL方式进行认证，数据通过SSL证书进行加密传输，安全性更高。此时需要配置连接实例的用户名和密码，以及证书文件。 安全协议设置为“SASL_PLAINTEXT”时，采用SASL方式进行认证，数据通过明文传输，性能更好。
Kafka单机实例 Kafka单机实例规格 Kafka单机实例由一个代理组成，兼容开源Kafka 2.7版本，适用于测试场景，不建议用于生产业务。 TPS（Transaction per second），在Kafka场景中，指每秒能写入到Kafka实例的最大消息数量。
关于Kafka的帮助手册阅读指引 受限于篇幅，我们提供的Kafka帮助手册重点描述产品相关的内容，以及与开源社区版Kafka的差异部分，例如华为云Kafka的产品规格、控制台操作、客户端对接等。
分布式消息服务Kafka版是一款基于开源社区版Kafka提供的消息队列服务，向用户提供计算、存储和带宽资源独占式的Kafka专享实例。
disk_encrypted Boolean 是否开启磁盘加密。 disk_encrypted_key String 磁盘加密key，未开启磁盘加密时为空。 kafka_private_connect_address String Kafka实例内网连接地址。
disk_encrypted Boolean 是否开启磁盘加密。 disk_encrypted_key String 磁盘加密key，未开启磁盘加密时为空。 kafka_private_connect_address String Kafka实例内网连接地址。
ssl_enable Boolean 否 是否打开SSL加密访问。 true：打开SSL加密访问。 false：不打开SSL加密访问。 retention_policy String 否 磁盘的容量到达容量阈值后，对于消息的处理策略。
其中涉及SASL认证配置，如果Kafka实例没有开启密文接入，使用的是不加密连接，请注释相关代码；如果Kafka实例开启了密文接入，则必须使用加密方式连接，请设置相关参数。
不支持磁盘加密。 请不要选用磁盘加密功能 400 DMS.00400136 Disk encrypted key is null. 磁盘加密的密钥是空值。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
