检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
文连接地址”/“公网明文连接地址”，具体以控制台显示为准。 如果是使用内网通过同一个VPC访问，Kafka连接地址如下图所示。 图1 使用内网通过同一个VPC访问Kafka实例的连接地址（内网连接地址） 图2 使用内网通过同一个VPC访问Kafka实例的连接地址（内网明文连接地址）
选。 ssl_enable 否 Boolean 是否开启SASL加密访问。 true：开启SASL加密访问。 false：关闭SASL加密访问。 kafka_security_protocol 否 String 开启SASL后使用的安全协议。 SASL_SSL: 使用SSL证书加密传输，支持账号密码认证，安全性更高。
如何修改安全协议？ Kafka实例的安全协议包括SASL_SSL和SASL_PLAINTEXT。 未开启IPv6的实例，安全协议支持在控制台修改。先在Kafka实例的详情页的“连接信息”区域，关闭密文接入，然后再开启密文接入，此时可以重新设置安全协议。 已开启IPv6的实例，实例创建后，不支持修改安全协议。
选择和配置安全组 Kafka实例支持使用内网通过同一个VPC访问、跨VPC访问、通过DNAT访问和公网访问，访问实例前，需要配置安全组。 使用内网通过同一个VPC访问实例 客户端和实例是否使用相同的安全组？ 是，如果保留了创建安全组后，系统默认添加的入方向“允许安全组内的弹性云服
安全 责任共担 身份认证与访问控制 数据保护技术 审计与日志 服务韧性 监控安全风险 认证证书
为什么不建议使用Sarama客户端收发消息？ 问题现象 使用Sarama客户端收发消息可能存在以下问题： Sarama客户端无法感知分区变化，当Topic分区数增加时，需要重启客户端后才能正常消费。 Sarama客户端消息最大处理时间（MaxProcessingTime）默认值为
Connect导致正在运行的Smart Connect任务丢失。 关闭Smart Connect 登录管理控制台。 在管理控制台左上角单击，选择Kafka实例所在的区域。 在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务Kafka版”，进入分布式消息服务Kafka专享版页面。
单线程发送、单线程消费并且不采用延迟队列、优先级队列等一些高级功能时，才能实现消息有序。 安全机制 支持SSL认证。 支持SSL、SASL身份认证和读写权限控制。 3.8.35版本：支持SSL认证。 AMQP-0-9-1版本：支持ACL访问控制。 事务性消息 支持 支持 支持
为什么JVM堆内存使用率出现明显波动？ JVM堆内存使用率在监控页面呈现锯齿状属于正常现象，在扩容规格或升级Kafka实例内核版本后，可能导致JVM堆内存使用率最大值升高、波动幅度变大，这种波动属于JVM堆内存回收的正常机制，对业务无影响。 父主题： 监控告警问题
groups.enable”的取值，请参考修改Kafka实例配置参数。 开启Smart Connect 登录管理控制台。 在管理控制台左上角单击，选择Kafka实例所在的区域。 在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务Kafka版”，进入分布式消息服务Kafka专享版页面。
通过公网访问Kafka（关闭SSL加密）。 入方向 TCP IPv4 9095 Kafka客户端所在的IP地址或地址组 通过公网访问Kafka（开启SSL加密）。 关闭IPv4公网访问（不支持修改SASL开关） 登录管理控制台。 在管理控制台左上角单击，选择Kafka实例所在的区域。 在管理控制台左上角单击，选择“应用中间件
否 当ssl_enable为true时，该参数必选， ssl_enable为false时，该参数无效。 认证用户名，只能由英文字母、数字、中划线、下划线组成，长度为4~64的字符。 password String 否 当ssl_enable为true时，该参数必选， ssl_enable为false时，该参数无效。
已创建Kafka实例，且实例状态为“运行中”。 已创建的OBS桶和Kafka实例需要在同一个区域。 配置Kafka数据转储至OBS 登录管理控制台。 在管理控制台左上角单击，选择Kafka实例所在的区域。 在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务Kafka版”，进入分布式消息服务Kafka专享版页面。
单击“确定”，完成Smart Connect任务的重启。 当页面左上方显示“成功重启任务xxx”时，表示成功重启Smart Connect任务。 父主题： 使用Smart Connect迁移数据
Kafka客户端所在的IP地址或地址组 使用内网通过同一个VPC访问Kafka实例（明文接入）。 使用对等连接跨VPC访问Kafka实例（明文接入）。 入方向 TCP IPv6 9192 Kafka客户端所在的IP地址或地址组 通过IPv6地址访问Kafka实例（关闭SSL加密）（内网和公网都适用）。
查询消费组信息 当前页面API为历史版本API，未来可能停止维护。请使用查询消费组信息。 URI GET /v1.0/{project_id}/instances/{instance_id}/manage/groups/{group} 参数说明如下表所示。 表1 参数说明 参数 类型
查询分区最早消息的位置 当前页面API为历史版本API，未来可能停止维护。请使用查询分区最早消息的位置。 URI GET /v1.0/{project_id}/instances/{instance_id}/manage/topics/{topic}/partitions/{pa
新增Kafka实例指定Topic分区 当前页面API为历史版本API，未来可能停止维护。请使用新增Kafka实例指定Topic分区。 URI POST /v1.0/{project_id}/instances/{instance_id}/manage/topics/{topic}
查询分区最新消息的位置 当前页面API为历史版本API，未来可能停止维护。请使用查询分区最新消息的位置。 URI GET /v1.0/{project_id}/instances/{instance_id}/manage/topics/{topic}/partitions/{pa
查询Kafka集群元数据信息 当前页面API为历史版本API，未来可能停止维护。请使用查询Kafka集群元数据信息。 URI GET /v1.0/{project_id}/instances/{instance_id}/manage/cluster 参数说明如下表所示。 表1 参数说明
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
