检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
coordinator_id Integer 协调器编号。 group_desc String 消费组描述。 lag Long 堆积数。 请求示例 GET https://{endpoint}/v2/{engine}/{project_id}/instances/{instance_id}/groups
项目ID，获取方式请参见获取项目ID。 instance_id 是 String 实例id 请求参数 无 响应参数 无 请求示例 DELETE https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/management
实例ID。 task_id 是 String Smart Connector任务ID。 请求参数 无 响应参数 无 请求示例 DELETE https://{endpoint}/v2/{project_id}/instances/{instance_id}/connector/tasks/{task_id}
项目ID，获取方式请参见获取项目ID。 instance_id 是 String 实例ID。 请求参数 无 响应参数 无 请求示例 删除指定的实例。 DELETE https://{endpoint}/v2/{project_id}/instances/{instance_id} 响应示例 无 SDK代码示例
通过异步方式将日志消息同步到消息服务，再通过其他组件对日志做实时或离线分析，也可用于关键日志信息收集进行应用监控。 日志同步主要有三个关键部分：日志采集客户端，Kafka消息队列以及后端的日志处理应用。 日志采集客户端，负责用户各类应用服务的日志数据采集，以消息方式将日志“批量”、“异步”发送到Kafka客户端。
发布此Topic，其他未授权的用户不能订阅/发布此Topic。“allow.everyone.if.no.acl.found”在配置参数中修改。 如果“allow.everyone.if.no.acl.found”为“false”，初始用户（即首次开启密文接入时设置的用户）拥有订
error_code String 错误码。 error_msg String 错误描述。 请求示例 创建一个消费组，消费组名为test。 POST https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/group {
长度为0~255个字符（中文也可以输入255个字符）。 由任意语种字母、数字、空格和字符组成，字符仅支持_ . : = + - @ 请求示例 GET https://{endpoint}/v2/{project_id}/kafka/{instance_id}/tags 响应示例 状态码：200 查询实例标签成功。
String 实例转储ID。 请求示例 新规格按需实例的开启Smart Connect，设置Smart Connect节点数量为2。 POST https://{endpoint}/v2/{project_id}/instances/{instance_id}/connector {
p。 message_offset、timestamp二者必选其一。 响应参数 无 请求示例 重置的消费进度到指定偏移量。 POST https://{endpoint}/v2/kafka/{project_id}/instances/{instance_id}/groups/{
的Kafka实例，用户在购买时会一次性付费，服务将在到期后自动停止使用。 如果在计费周期内不再使用包年/包月资源，您可以执行退订操作，系统将根据资源是否属于五天无理由退订、是否使用代金券和折扣券等条件返还一定金额到您的账户。详细的退订规则请参见云服务退订规则概览。需要注意，如果实
与开源Kafka的差异 分布式消息服务Kafka版在兼容开源Kafka基础上，对版本特性做了一定程度的定制和增强，所以，除了拥有开源Kafka的优点，分布式消息服务Kafka版提供了更多可靠、实用的特性。 表1 分布式消息服务Kafka版与开源Kafka的差异说明 对比类 对比项
因按需Kafka实例自动扣费导致欠费后，账号将变成欠费状态，Kafka实例将陆续进入宽限期和保留期。 图3 按需计费Kafka实例生命周期 欠费预警 系统会在每个计费周期后的一段时间对按需计费资源进行扣费。当您的账户被扣为负值时，我们将通过邮件、短信和站内信的方式通知到华为云账号的创建者。
实例正常运行，此阶段为有效期；Kafka实例到期而未续费时，将陆续进入宽限期和保留期。 图3 包年/包月Kafka实例生命周期 到期预警 包年/包月Kafka实例在到期前第7天内，系统将向用户推送到期预警消息。预警消息将通过邮件、短信和站内信的方式通知到华为云账号的创建者。 到期后影响
Integer 协调器编号。 group_desc String 消费组描述。 lag Long 堆积数。 请求示例 查询消费组列表。 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/groups?offset=
broker_address String broker地址 join_time Long 加入时间 请求示例 查询Topic的当前生产者列表 GET https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/topics/{topic}/producers
权限类型。 all：拥有发布、订阅权限; pub：拥有发布权限; sub：拥有订阅权限。 请求示例 查询Topic的用户权限。 GET https://{endpoint}/v1/{project_id}/instances/{instance_id}/topics/{topic_name}/accesspolicy
如果业务要求所有消费者在同一个消费组内，即group.id相同，解决方法：为所有消费者授权相同的Topic访问权限。 如果消费者不需要在同一个消费组内，解决方法：修改group.id，让每个消费者单独在一个消费组内。 父主题： Topic和分区问题
消息堆积处理建议 方案概述 Kafka将Topic划分为多个分区，消息被分布式存储在分区中。同一个消费组内，一个消费者可同时消费多个分区，但一个分区在同一时刻只能被一个消费者消费。 在消息处理过程中，如果客户端的消费速度跟不上服务端的发送速度，未处理的消息会越来越多，这部分消息就
参数类型 描述 result Boolean 报告删除结果 id String 报告ID 请求示例 批量删除消息积压诊断报告。 DELETE https://{endpoint}/v2/{project_id}/kafka/instances/{instance_id}/message-diagnosis-tasks
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
