创建Kafka消费组 消费者是从Topic订阅消息的一方，消费组是由一个或多个消费者组成的。同一个消费组内，一个消费者可同时消费多个分区，但一个分区在同一时刻只能被一个消费者消费。 图1 消费关系示例图 “auto.create.groups.enable”表示在消费者进入未创建的消费组时，会自动创建此消费组。

查看更多 →

日志出现重复/丢失的原因 日志出现重复 原因一：日志文件转储，且转储文件仍被匹配到。 详细说明：如果配置日志路径文件名中有通配符，如配置为/tmp/*.log，当/tmp/test.log文件转储为/tmp/test.001.log后，因仍被通配规则匹配到，会被视为新文件，则会被重新采集。

查看更多 →

重置消费组消费进度到指定位置 功能介绍 Kafka实例不支持在线重置消费进度。在执行重置消费进度之前，必须停止被重置消费组客户端。 在停止被重置消费组客户端后，需要经过ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG配置的时间（默认10000毫秒），服务端才认为消费组客户端真正下线。

查看更多 →

消费消息接口说明 功能介绍 消费指定队列中的消息，可同时消费多条消息。 当队列中消息较少时，单次消费返回的消息数量可能会少于指定条数，但多次消费最终可获取全部消息。当返回的消息为空数组时，表示未消费到消息。 endpoint为https://{rest_connect_addre

查看更多 →

是否允许以广播模式消费 是否设置为广播消费。 若开启广播消费，每条消息都会被消费组内的所有消费者消费一次。否则，每条消息只会被消费组内的某一消费者消费。 是否顺序消费 RocketMQ实例的版本为5.x时，需要设置此参数。 开启顺序消费后，消费者将顺序消费消息。按顺序消费可以保证消息的消费顺

查看更多 →

若消费组从未提交过offset，当Kafka实例重启后，该消费组会被删除。 删除消费组会导致消费进度丢失，造成重新消费或重复消费等情况。 前提条件 待删除消费组的状态为“EMPTY”。 在控制台删除消费组 登录管理控制台。 在管理控制台左上角单击，选择Kafka实例所在的区域。 在管理控制台左上角单击，选择“应用中间件

查看更多 →

查询IDE实例名是否重复 功能介绍 查询IDE实例名是否重复 调试 您可以在 API Explorer 中调试该接口，支持自动认证鉴权。API Explorer可以自动生成SDK代码示例，并提供SDK代码示例调试功能。 URI GET /v2/instances/duplicate 表1

查看更多 →

机会点重复处理原则？ PCE机会点重复处理原则：当多个PO或者HO出现重复时，仅允许一个PCE机会点通过。 多个PO重复：原则上以“机会点验证通过”的提交时间点为准；伙伴提交的机会点状态为“机会点验证通过”后，不再接受其他伙伴提交的重复机会点。 PO和HO重复：HO以提交时间点为准，PO以

查看更多 →

重置消费组消费进度到指定位置 功能介绍 Kafka实例不支持在线重置消费进度。在执行重置消费进度之前，必须停止被重置消费组客户端。停止待重置消费组客户端，然后等待一段时间（即ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG配置的时间，默认为1000

查看更多 →

收发顺序消息 顺序消息是分布式消息服务RocketMQ版提供的一种严格按照顺序来发布和消费的消息类型。 顺序消息分为全局顺序消息和分区顺序消息： 全局顺序消息：对于指定的一个Topic，将队列数量设置为1，这个队列内所有消息按照严格的先入先出FIFO（First In First

查看更多 →

消费数据集 订阅数据集 下载数据集 取消订阅数据集 父主题： 数据集

查看更多 →

查看App消费状态 功能介绍 本接口用于查询APP消费状态。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/apps/{app_name}/streams/{stream_name} 表1 路径参数 参数 是否必选 参数类型 描述 project_id

查看更多 →

分区编号。 lag Long 剩余可消费消息数，即消息堆积数。 topic String topic名称。 message_current_offset Long 当前消费进度。 message_log_end_offset Long 最大消息位置（LEO）。 请求示例 GET

查看更多 →

String 实例ID。 group 是 String 消费组ID。 请求参数 表2 请求Body参数 参数 是否必选 参数类型 描述 group_name 否 String 消费组名称 group_desc 否 String 消费组描述 响应参数 无 请求示例 PUT https:

查看更多 →

最大重试次数，取值范围为1~16。 enabled 否 Boolean 是否可以消费。 consume_orderly 否 Boolean 是否按顺序消费（仅RocketMQ实例5.x版本需要填写此参数）。 group_desc 否 String 消费组描述，长度0~200个字符。 响应参数 状态码： 200

查看更多 →

02.html 调用流程 开发建议及注意事项 客户消费记录反映客户在资源消耗情况，不包含客户的实际扣费信息。 客户消费主要用于查看所有客户的消费情况。客户消费并非伙伴的账单，不能作为伙伴与华为云结算、还款与开票的依据。 父主题： 管理账单

查看更多 →

为空串时，作为筛选条件。 bill_type 否 Integer - 账单类型。 1：消费-新购 2：消费-续订 3：消费-变更 4：退款-退订 5：消费-使用 8：消费-自动续订 9：调账-补偿 12：消费-按时计费 13：消费-退订手续费 14：消费-服务支持计划月末扣费 16：调账-扣费

查看更多 →

Service也需要增加灰度发布相关的配置。 消息灰度 微服务蓝绿或灰度发布的业务场景中，灰度实例生产或消费的消息可能需要特殊处理，这时可以挂载Sermant消息灰度插件实现消息的灰度能力，灰度实例生产者或灰度流量生产灰度消息，灰度消费者消费灰度消息。 消息灰度配置： 配置项：grayscale.mq.config

查看更多 →

避免物品重复推荐（曝光过滤） 本实践介绍用户在客户端浏览、点击过的某些商品，在规定的时间内，重复请求推荐接口，不会被再次推荐。 功能说明 该功能使用涉及两部分：实时行为数据的接入和在线服务配置行为过滤。当数据源部分开启近线行为实时接入之后，并且用户通过上传实时行为数据，系统才具备

查看更多 →

查询告警模板名称是否重复 功能介绍 查询告警模板名称是否重复 URI GET /v1/projects/{service_id}/alert-templates/name 表1 路径参数 参数 是否必选 参数类型 描述 service_id 是 String 服务id 表2 Query参数

查看更多 →

当无法确认消息是否已发送成功，生产者需要将消息重复发送给分布式消息服务Kafka版。 当重复收到已处理过的消息，消费者需要告诉分布式消息服务Kafka版消费成功且保证不重复处理。 消息可以批量生产和消费 为提高消息发送和消息消费效率，推荐使用批量消息发送和消费。 图1 消息批量生产与消费 图2

查看更多 →