检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
连接信息 用户名 - 开启密文接入后，连接实例的用户名。 内网访问 明文接入 是否开启明文接入。 内网明文连接地址 明文接入开启后，才显示此参数。 密文接入 是否开启密文接入。 内网密文连接地址 密文接入开启后，才显示此参数。 启用的安全协议 密文接入开启后，才显示此参数。 公网访问
0/17 通过VPC终端节点实现跨VPC访问Kafka实例（密文接入和明文接入都适用）。 入方向 TCP IPv4 9011 Kafka客户端所在的IP地址或地址组 使用DNAT访问Kafka实例（密文接入和明文接入都适用）。 父主题： 配置Kafka网络连接
实例是否支持内网PLAINTEXT访问接入方式。 true：实例支持内网PLAINTEXT访问方式接入方式。 false：实例不支持内网PLAINTEXT访问接入方式。 private_plain_address String kafka内网PLAINTEXT接入方式连接地址。 private_plain_domain_name
实例是否支持内网PLAINTEXT访问接入方式。 true：实例支持内网PLAINTEXT访问方式接入方式。 false：实例不支持内网PLAINTEXT访问接入方式。 private_plain_address String kafka内网PLAINTEXT接入方式连接地址。 private_plain_domain_name
实例是否支持内网PLAINTEXT访问接入方式。 true：实例支持内网PLAINTEXT访问方式接入方式。 false：实例不支持内网PLAINTEXT访问接入方式。 private_plain_address String kafka内网PLAINTEXT接入方式连接地址。 private_plain_domain_name
创建VPC对等连接，将两个VPC的网络打通，实现跨VPC访问。具体步骤请参考对等连接。注意修改Kafka实例的安全组，允许端口9092（明文接入）/9093（密文接入）被外部请求访问。 利用VPC终端节点在不同VPC间建立跨VPC的连接通道，实现Kafka客户端通过内网访问Kafka实例，具体
跳转到“后台任务管理”页面。 当任务状态显示为“成功”时，表示成功开启公网访问。 图2 开启公网访问 开启公网访问后，需要设置接入方式（明文接入、密文接入）和对应的安全组规则，才能成功连接Kafka。连接Kafka的具体操作请参考连接实例。 表3 Kafka实例安全组规则（IPv4公网访问）
口。 topic_name：Topic名称。 sasl_plain_username/sasl_plain_password：首次开启密文接入时设置的用户名与密码，或者创建用户时设置的用户名和密码。为了确保用户名和密码的安全性，建议对用户名和密码进行加密处理，使用时解密。 context
Java Java客户端接入示例 Java开发环境搭建
2以上时，支持通过kafka-topics.sh修改Topic分区数。 已开启密文接入的实例，“allow.everyone.if.no.acl.found”设置为“false”时，无法通过客户端修改Topic分区数。 未开启密文接入的Kafka实例，在Kafka客户端的“/bin”目录下，通过以下命令修改Topic分区数。
配置Kafka访问控制 配置Kafka实例的明文/密文接入 制作和替换Kafka的SSL证书 JKS格式SSL证书转换PEM格式 配置Kafka的SSL双向认证 配置Kafka ACL用户 父主题： 连接实例
未开启“Kafka自动创建Topic”功能时，必须先创建Topic，然后客户端才可以连接Kafka实例生产消费消息。 密文接入信息 如果实例开启密文接入，则需要获得连接实例的用户名与密码、SASL认证机制和Kafka安全协议。Kafka安全协议设置为“SASL_SSL”时，还需要获取SSL证书。
(ID)、堆积数、描述或者关键字，按“Enter”。 （可选）如果需要刷新消费组列表，在右上角单击。 查看消费组列表（Kafka客户端） 未开启密文接入的Kafka实例，在Kafka客户端的“/bin”目录下，通过以下命令查询消费组列表。 ./kafka-consumer-groups.sh
修改实例跨VPC访问的内网IP 查询Kafka集群元数据信息 查询Kafka实例的协调器信息 修改Kafka实例Topic分区的副本 修改Kafka的接入方式 查询topic的磁盘存储情况 Kafka实例开始分区重平衡任务 关闭Kafka Manager 删除用户/客户端流控配置 查询用户/客户端流控配置
修改Kafka的配置参数。 开启/关闭自动创建Topic。 容量阈值策略变更 修改Kafka实例的容量阈值策略。 Kafka动态配置SSL 修改明文接入/密文接入。 配置公网访问 开启/关闭公网访问。 开启Smart Connect 开启Smart Connect功能。 关闭Smart Connect
在左侧导航栏选择“Topic管理”，进入Topic列表页面。 执行以下步骤，弹出“消息删除”对话框。 如果实例未开启密文接入功能，在待删除消息的Topic所在行，单击“消息删除”。 如果实例已开启密文接入功能，在待删除消息的Topic所在行，单击“更多 > 消息删除”。 设置消息删除参数，如表1所示。
弹出“删除消费组”对话框，单击“确定”，完成消费组的删除。 使用命令行工具删除消费组 以下操作命令以Linux系统为例进行说明： 未开启密文接入的Kafka实例，在Kafka客户端的“/bin”目录下，通过以下命令删除消费组。 ./kafka-consumer-groups.sh --bootstrap-server
Topic名称开头包含特殊字符，例如“#”号时，监控数据无法展示。 已开启密文接入的实例，“allow.everyone.if.no.acl.found”设置为“false”时，无法通过客户端创建Topic。 未开启密文接入的Kafka实例，在Kafka客户端的“/bin”目录下，通过以下命令创建Topic。
者地址和客户端ID。 （可选）如果需要查询某个消费者，在搜索框中，输入消费者ID，按“Enter”。 查看消费者列表（客户端） 未开启密文接入的Kafka实例，在Kafka客户端的“/bin”目录下，通过以下命令查询消费者列表。 ./kafka-consumer-groups.sh
（可选）如果需要查询某个Topic的消费进度，在搜索框中，输入Topic名称，按“Enter”。 查看消费进度（Kafka客户端） 未开启密文接入的Kafka实例，在Kafka客户端的“/bin”目录下，通过以下命令查询消费进度。 ./kafka-consumer-groups.sh
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
