检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
版本发布说明 表1列出了分布式消息服务Kafka版相对开源版本新增/优化的特性。 表1 版本发布说明 实例版本 发布时间 新增/优化特性 1.1.0和2.7 2023年7月 控制台支持查看重平衡日志 1.1.0和2.7 2023年4月 控制台支持手动创建消费组 1.1.0和2.7
在添加订阅后，对应的订阅终端会收到订阅通知，用户要选择确认订阅，后续才能收到告警信息。 通知周期 保持默认，即如果触发告警，每天发送告警通知。 生效时间 告警规则仅在生效时间内发送通知消息，保持默认。 通知内容模板 选择“默认”。 通知策略创建成功后，返回“创建告警规则”页面。 在“通知策略”后，单击，然后在下拉框中选择新创建的通知策略。
在Kafka控制台，单击Kafka实例名称，进入实例详情页面。在“基本信息”页签，查看公网IP地址（即“公网连接地址”）。 如果您需要连接Kafka实例，请参考连接Kafka。 父主题： 连接问题
Kafka支持SASL客户端认证、调用接口支持Token和AK/SK两种认证，Kerberos认证目前不支持。 如果使用SASL认证方式，则在开源客户端基础上使用分布式消息服务Kafka版提供的证书文件。具体操作参考使用客户端连接Kafka（开启SASL）。 父主题： 连接问题
partition Integer 分区编号。 message_offset Long 最早消息位置。 timestamp Long 最早消息时间戳。 响应示例 { "topic": "mytest", "partition": 0, "message_offset
partition Integer 分区编号。 message_offset Long 最新消息位置。 timestamp Long 最新消息时间戳。 响应示例 { "topic": "mytest", "partition": 0, "message_offset":
NULL 默认值：换行符“\n”。 deliver_time_interval 是 Integer 根据用户配置的时间，周期性的将数据导入OBS，若某个时间段内无数据，则此时间段不会生成打包文件。 取值范围：30～900 单位：秒。 说明： 使用OBS通道转储流式数据时该参数为必选配置。
业务数据增长较快，已有的磁盘空间不能满足业务数据需要。 节点内磁盘使用率不均衡，生产的消息集中在某个分区，导致分区所在的磁盘写满。 Topic的数据老化时间设置过大，保存了过多的历史数据，容易导致磁盘写满。 实施步骤 CPU使用率高的处理措施： 优化线程参数num.io.threads、num
否 Integer 查询的任务个数。 begin_time 否 String 查询任务的最小时间，格式为YYYYMMDDHHmmss。 end_time 否 String 查询任务的最大时间，格式为YYYYMMDDHHmmss。 请求参数 无 响应参数 状态码： 200 表3 响应Body参数
密文接入成功开启后，用户名不支持修改。 kafka安全协议、SASL PLAIN机制、用户名和密码在客户端连接已开启密文接入的Kafka实例时需要配置，具体请参考使用客户端连接Kafka（开启SASL）。 关闭明文接入 登录管理控制台。 在管理控制台左上角单击，选择区域。 请选择Kafka实例所在的区域。
是否必选 参数类型 描述 user 否 String 用户名。 不对全部用户/客户端限流时，用户名和客户端ID不能同时为空。 client 否 String 客户端ID。 不对全部用户/客户端限流时，用户名和客户端ID不能同时为空。 user-default 否 Boolean 是否使用用户默认设置。
是否必选 参数类型 描述 user 否 String 用户名。 不对全部用户/客户端限流时，用户名和客户端ID不能同时为空。 client 否 String 客户端ID。 不对全部用户/客户端限流时，用户名和客户端ID不能同时为空。 user-default 否 Boolean 是否使用用户默认设置。
ID。 vpc_name String VPC的名称。 created_at String 完成创建时间。 格式为时间戳，指从格林威治时间 1970年01月01日00时00分00秒起至指定时间的偏差总毫秒数。 subnet_name String 子网名称。 subnet_cidr String
分区编号。 message_offset Long 消息位置。 size Integer 消息大小，单位字节。 timestamp Long 消息时间戳。 响应示例 { "message": { "topic": "mytest",
是否为contoller节点。 version String 服务端版本。 register_time Long broker注册时间，为unix时间戳格式。 is_health Boolean Kafka实例节点的连通性是否正常。 请求示例 GET https://{endpo
是否必选 参数类型 描述 user 否 String 用户名。 不对全部用户/客户端限流时，用户名和客户端ID不能同时为空。 client 否 String 客户端ID。 不对全部用户/客户端限流时，用户名和客户端ID不能同时为空。 user-default 否 Boolean 是否使用用户默认设置。
登录Kafka Manager的帐号是否可以设置为只读帐号？ 不支持设置为只读帐号。 父主题： Kafka Manager问题
符前增加转义字符\，比如\或者"。 maintain_begin 否 String 维护时间窗开始时间，格式为HH:mm:ss。 maintain_end 否 String 维护时间窗结束时间，格式为HH:mm:ss。 security_group_id 否 String 安全组ID。
Integer topic分区数，设置消费的并发数。 retention_time Integer 消息老化时间。 sync_replication Boolean 是否开启同步复制，开启后，客户端生产消息时相应的也要设置acks=-1，否则不生效，默认关闭。 sync_message_flush
单击右上角的“更多 > 转包周期”，跳转到“按需转包年/包月”页面。 选择Kafka实例的购买时长，判断是否勾选“自动续费”，确认预计到期时间和配置费用后单击“去支付”。 图1 按需转包年/包月 进入支付页面，选择支付方式，确认付款，支付订单后即可完成按需转包年/包月。 父主题：
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
