检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
enable”表示在消费者进入未创建的消费组时，会自动创建此消费组。 如果在配置参数中设置“auto.create.groups.enable”为“false”，在消费消息前，需要先创建消费组，否则会导致消费失败。 如果在配置参数中设置“auto.create.groups.enable”为“true
对端Kafka开启SASL_SSL时设置的用户名，或者创建SASL_SSL用户时设置的用户名。（仅源端类型为Kafka且对端Kafka认证方式为“SASL_SSL”时需要填写） password 否 String 对端Kafka开启SASL_SSL时设置的密码，或者创建SASL_SSL用户时设置的密码。（
在分布式消息服务Kafka版提供的原生Kafka SDK中，消费者可以自定义拉取消息的时长，如果需要长时间的拉取消息，只需要把poll(long)方法的参数设置合适的值即可。但是这样的长连接可能会对客户端和服务端造成一定的压力，特别是分区数较多且每个消费者开启多个线程的情况下。 如图1所示，Top
在告警规则页面，设置告警信息。 创建告警规则操作，请查看创建告警规则。 设置告警名称和告警的描述。 设置告警策略。 如下图所示，在进行指标监控时，如果连续1次，磁盘容量使用率原始值>=80%，则产生告警，如果未及时处理，则产生告警通知。 图1 设置告警策略 设置“发送通知”开关。
取。 消息生产与消费的幂等传递 分布式消息服务Kafka版设计了一系列可靠性保障措施，确保消息不丢失。例如使用消息同步存储机制防止系统与服务器层面的异常重启或者掉电，使用消息确认（ACK）机制解决消息传输过程中遇到的异常。 考虑到网络异常等极端情况，用户除了做好消息生产与消费的确
Kafka实例规格为1200MB时，公网带宽取值范围8到2400，且必须为实例节点个数的倍数。 publicip_id String 否 实例绑定的弹性IP地址的ID。 以英文逗号隔开多个弹性IP地址的ID。 如果开启了公网访问功能（即enable_publicip为true），该字段为必选。 ssl_enable Boolean
租户侧连接地址。 disk_encrypted Boolean 是否开启磁盘加密。 disk_encrypted_key String 磁盘加密key，未开启磁盘加密时为空。 kafka_private_connect_address String Kafka实例内网连接地址。 ka
租户侧连接地址。 disk_encrypted Boolean 是否开启磁盘加密。 disk_encrypted_key String 磁盘加密key，未开启磁盘加密时为空。 kafka_private_connect_address String Kafka实例内网连接地址。 ka
pod_connect_address String 租户侧连接地址。 disk_encrypted Boolean 是否开启磁盘加密。 是：开启 否：不开启 kafka_private_connect_address String Kafka实例私有连接地址。 ces_version String 云监控版本。
老化时间 如果Topic已经设置了老化时间，此时“配置参数”中的log.retention.hours值将不对此Topic生效。仅在Topic中未设置老化时间时，“配置参数”中的log.retention.hours值才会对此Topic生效。 例如：Topic01设置的老化时间为60小时，“配置参数”中的log
pod_connect_address String 租户侧连接地址。 disk_encrypted Boolean 是否开启磁盘加密。 kafka_private_connect_address String Kafka实例私有连接地址。 ces_version String 云监控版本。
图1 订阅关系 分区信息：包含分区编号、最小偏移量、最大偏移量、消息数和消息更新时间。 图2 分区信息 生产者信息：包含Broker地址、生产者地址和加入时间。 仅当生产者正在往Topic中生产消息时，才显示生产者信息。 2023年7月10日以及之前创建的Topic，在Topic详情页面不显示“生产者”页签。
Kafka Manager”后，单击，关闭Kafka Manager。 关闭Kafka Manager后，控制台不显示Kafka Manager连接地址，不支持重置Kafka Manager密码和重启Kafka Manager功能。 父主题： 管理Kafka Manager
副本的Topic需要在生产客户端配置重试机制，方法如下： 生产客户端为Kafka开源客户端时，检查是否配置retries参数，建议此参数值设置为3~5。 生产客户端为Flink客户端时，检查是否配置重启策略，配置重启策略可以参考如下代码。 StreamExecutionEnvironment
group_id String 消费组ID。 id Integer 对应协调器的broker id。 host String 对应协调器的地址。 port Integer 端口号。 响应示例 { "coordinators": [ {
backoff.ms=1000。 request.timeout.ms 30000 结合实际业务调整 设置一个请求最大等待时间（单位为ms），超过这个时间则会抛Timeout异常。 超时时间如果设置大一些，如127000（127秒），高并发的场景中，能减少发送失败的情况。 block.on
Kafka服务和ZK是部署在相同的虚拟机中，还是分开部署？ Kafka服务和ZK部署在相同的虚拟机中。 父主题： 实例问题
进入“费用中心 > 续费管理”页面。 自定义查询条件。 可在“到期转按需项”页签查询已经设置到期转按需的资源。 可对“手动续费项”、“自动续费项”、“到期不续费项”页签的资源设置到期转按需的操作。 设置包年/包月资源到期后转按需。 单个资源到期转按需：选择需要更改计费模式的Kafka实例，单击操作列“更多
单击Kafka实例的名称，进入实例详情页面。 在左侧导航栏单击“流控管理 > 流控监控”，进入流控监控页面。 设置查询带宽使用量的参数。 表1 查询带宽使用量的参数说明 参数 说明 统计方式 设置带宽使用量的统计方式。 前n个：统计带宽使用量排名前x个的用户/客户端/Topic，x由您自行输入。
配置发送失败重试：retries=3 发送优化：对于时延敏感的信息，设置linger.ms=0。对于时延不敏感的信息，设置linger.ms在100~1000之间。 生产端的JVM内存要足够，避免内存不足导致发送阻塞。 时间戳设置为与当地时间一致，避免时间戳为未来时间导致消息无法老化。 尽
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
