需要企业自己负责。而当迁移到云端，云服务提供商和云消费者在安全性问题上发生了变化——云提供商和云消费者对云系统中的计算资源有不同程度的控制。与传统IT系统（一个组织控制整个计算资源堆栈和系统的整个生命周期）相比，云提供商和云消费者协作设计、构建、部署和操作基于云的系统。 华为云作

查看更多 →

properties 配置文件中“group.id”指定的消费者组默认为“example-group1”。用户可根据业务需要，自定义其他消费者组。每次消费时生效。 执行命令时默认会读取当前消费者组中未被处理的消息。如果在配置文件指定了新的消费者组且命令中增加参数“--from-beginni

查看更多 →

properties 配置文件中“group.id”指定的消费者组默认为“example-group1”。用户可根据业务需要，自定义其他消费者组。每次消费时生效。 执行命令时默认会读取当前消费者组中未被处理的消息。如果在配置文件指定了新的消费者组且命令中增加参数“--from-beginni

查看更多 →

消费确认接口说明 功能介绍 确认已经消费指定消息。 在消费者消费消息期间，消息仍然停留在队列中，但消息从被消费开始的30秒内不能被该消费组再次消费，若在这30秒内没有被消费者确认消费，则MQS认为消息未消费成功，将可以被继续消费。 endpoint为https://{rest_c

查看更多 →

定时消息适用于以下场景： 消息对应的业务逻辑有时间窗口要求，如电商交易中超时未支付关闭订单的场景。在订单创建时发送一条定时消息，5分钟以后投递给消费者，消费者收到此消息后需要判断对应订单是否完成支付，如果未完成支付，则关闭订单。如果已完成，则忽略。 通过消息触发定时任务的场景，如在某些固定时间点向用户发送提醒消息。

查看更多 →

定时消息适用于以下场景： 消息对应的业务逻辑有时间窗口要求，如电商交易中超时未支付关闭订单的场景。在订单创建时发送一条定时消息，5分钟以后投递给消费者，消费者收到此消息后需要判断对应订单是否完成支付，如果未完成支付，则关闭订单。如果已完成，则忽略。 通过消息触发定时任务的场景，如在某些固定时间点向用户发送提醒消息。

查看更多 →

评估、样板管理模块，支持多业态管理。 安全管理 主要功能：安全资料档案，安全活动管理，在线学习考核，危险源管理，安全巡检等模块，可对接 AIOT 安全监控设备。 合作方考评 主要功能：提供供应商库、供方考察（含移动考察）、供方评估（含移动评估）、供方定级、供方处置、供方投诉、供方

查看更多 →

建议预先创建Topic，根据业务需求合理规划Partition数目，Partition数目限制了消费者的并发数。 消息key值选取一定是可变的，防止由于消息key值不变导致消息分布不均匀。 消费者尽量使用主动提交offset的方式，避免重复消费。 父主题： 开发Kafka应用

查看更多 →

需要组织会务的人员。一般为公司行政、秘书等会务组织者。 会务管理员 可以使用会务应用，创建大会，可以使用个人会务后台。 需要辅助组织会务的人员。一般为公司行政、秘书等会务组织者。 会务组成员 可以使用会务应用，编辑某个大会内容，可以使用个人会务后台。 参加会议的人。 与会者 享受会务通带来的会务服务。

查看更多 →

重启消费业务，使得消费者从新Kafka实例中消费消息。 观察消费者是否能正常从新Kafka实例中获取数据。 迁移结束。 本方案为业界通用的迁移方案，操作步骤简单，迁移过程由业务侧自主控制，整个过程中消息不会存在乱序问题，适用于对消息顺序有要求的场景。但是该方案中需要等待消费者业务直至消费

查看更多 →

消息的最终目的在于将消息内容传递给其他系统，使对方能按照约定处理该消息。 消费者 消费者为从消息主题（Topic）订阅消息的一方，订阅消息的最终目的在于处理消息内容。如日志集成场景中，监控告警平台作为消费者从Topic订阅日志消息，识别出告警日志并发送告警消息/邮件。 分区 Ka

查看更多 →

该指标用于统计消费组指定队列可以消费的消息个数。 出现该告警时，首先排查消费者代码逻辑是否有误，例如消费者出现了异常不再消费等。其次，可以考虑加快消息的消费，例如增加队列消费者，并确保分区数大于或等于消费者数。 配置Kafka监控告警 登录管理控制台。 在管理控制台左上角单击，选择区域。

查看更多 →

如果生产速度过快（例如执行批处理任务），或者消费者由于各种原因（例如消费者下线、宕机）长时间内无法消费消息，导致消息大量堆积，使得内存使用率过高，换页频繁，可能会影响其他队列的消息收发。这种场景下，建议您启用惰性队列。 惰性队列（Lazy Queue）会尽可能的将消息存入磁盘中，在消费者消费到相应的消息时

查看更多 →

clientId为维度统计消息消费详情。） clientId clientId 客户端实例标识 - ENUM LAST group 消费者组 消费者组 - ENUM LAST pid pid pid - STRING LAST concurrentMax 最大并发 消费消息最大并发

查看更多 →

Controller连接Broker的超时时间，一般不需要调整。 group.max.session.timeout.ms Consumer注册时允许的最大会话超时时间。单位：毫秒。 1800000 允许Consumer配置的session.timeout.ms的最大值（不包含此值）。 group

查看更多 →

权益券 用于激励生态对象加入生态政策（如各类伙伴计划、初创计划、开发者计划等）或参加生态活动（如开发者大赛、HC大会等），满足生态政策要求或基于生态活动发放的固定额度代金券。 父主题： 术语&缩略语解释

查看更多 →

consumer_tag String 消费者标识 channel_details ChannelDetails object 消费者连接信息 ack_required Boolean 消费者客户端是否设置手动ack prefetch_count Integer 消费者客户端预取值 表5 ChannelDetails

查看更多 →

commit设定，true表示自动提交（默认）。 自动提交策略由消费者协调器（Coordinator）每隔${auto.commit.interval.ms}毫秒执行一次偏移量的提交；手动提交需要由客户端自己控制偏移量的提交。 自动提交 在创建一个消费者时，默认是自动提交偏移量，默认的提交间隔是50

查看更多 →

会务通支持移动端和PC端吗？ 支持。 会务管理员可在个人会务后台和移动客户端创建大会，添加会务组成员，创建IM互动群，发布群资讯等。 会务组成员可登录移动和PC客户端，可在IM互动群交流互动：发送消息，图片，语音，视频等。 父主题： 应用

查看更多 →

Kafka允许的最大批处理大小，如果启用消息压缩，则表示压缩后的最大批处理大小。 如果增加“批处理消息最大值”的值，且存在消费者版本早于0.10.2，此时消费者的“fetch size”值也必须增加，以便消费者可以获取增加后的批处理大小。 描述 Topic的描述信息。 修改同步复制、同步落盘、消息时间戳类型和批处理消息最大值，不会重启实例。

查看更多 →

查询消费组列表 创建消费组或批量删除消费组 批量修改消费组 删除指定消费组 查询指定消费组 修改消费组 查询消费列表或详情 重置消费进度 查询消费者列表 父主题： API V2（推荐）

查看更多 →