建议在Kafka客户端侧配置日志转储，否则容易引起磁盘被日志打满的情况。 一个消费组下的消费者在连接同一个MQS时，最多允许该消费组下的500个消费者进行连接，超过数量的消费者将连接失败。如果一个消费组下有超过500个消费者，且需要连接同一个MQS，需要把消费者拆分到多个消费组下。 若ROMA Connect实例的

查看更多 →

送成功后，在服务端中就会存在两条内容相同的消息，最终消费者会消费到两条内容一样的重复消息。 消费者消费消息时发生消息重复： 消费者消费消息时，服务端将消息投递至消费者并完成业务处理。如果此时发生网络闪断，导致服务端未收到消费者的响应，此时服务端会认为消息投递失败。为了保证消息至少

查看更多 →

latest：自动复位offset为最新 none：如果没有发现offset，则向消费者抛出异常 anything else：向消费者抛出异常。 说明： 如果将此配置设置为latest，新增分区时，生产者可能会在消费者重置初始偏移量之前开始向新增加的分区发送消息，从而导致部分消息丢失。 connections

查看更多 →

中。如果消费者在启动消费时从最新的消息开始消费，则会直接从内存中获取消息进行消费。 当消费者不是从最新的消息开始消费时，RocketMQ需要从磁盘中读取历史消息保存到内存中，由此产生了冷读现象。如果有大量消费者触发冷读，使I/O压力飙升，可能会达到磁盘性能瓶颈，造成消费者拉取消息时延增大或失败，进而导致消费速率下降。

查看更多 →

如果消息组中没有在线的消费者（如empty状态），是否14天后会自动被删除？ 消息组中没有在线的消费者（如empty状态），14天后是否会自动被删除与offsets.retention.minutes、auto.create.groups.enable参数有关： 2023年4月25日前创建的实例，auto

查看更多 →

生产者向消息主题发布消息，多个消费者订阅该消息主题的消息，生产者与消费者彼此并无直接关系。 生产者（Producer） 向Topic（消息主题）发布消息的一方。发布消息的最终目的在于将消息内容传递给其他系统/模块，使对方按照约定处理该消息。 消费者（Consumer） 从Topi

查看更多 →

提交成功：允许消费者消费此事务消息。 回滚：事务消息将被丢弃，不允许消费者消费此事务消息。 未知，待确认：事务消息状态暂时无法确定，等待固定时间后，服务端向生产者进行消息回查。 生产耗时 生产者发送消息的耗时。 单位：毫秒 生产地址 生产者的IP地址。 消费者状态 消费者状态如下： 消费成功

查看更多 →

租户或用户到可视范围，用于将数据集授权给数据消费者（这里的数据消费者为其他租户下的数据消费者和数据管理者，下文中相同），被授权的数据消费者在数据集发布成功后可以查看和订阅该数据集并下载到OBS桶。发布数据集所在租户下的数据管理者和消费者可以查看和订阅该租户下发布的数据集并下载到OBS桶，无需授权。

查看更多 →

定时间后才会发送给消费者进行消费。 顺序消息：消费者按照消息发送的顺序来消费消息。 事务消息：提供类似X/Open XA的分布事务功能，通过事务消息能达到分布式事务的最终一致。 支持的高级特性 分布式消息服务RocketMQ版支持4种高级特性。 消息过滤：消费者根据分布式消息服务

查看更多 →

数据集 数据集有哪些密级 数据管理者与数据消费者的区别是什么 未发布的数据资产可以提供给数据消费者使用吗 如何发布数据集 如何订阅数据集 如何下载数据集 数据集下载成功后有哪些使用方式 父主题： 常见问题

查看更多 →

当数据集的密级等级是秘密、机密或绝密时，只有被授权的数据消费者和发布该数据集所在租户下的数据管理者和消费者有权限订阅该数据集。如果发布该数据集时已设置“本租户内是否免审批”为“否”，则只有发布该数据集所在租户下的“Data Owner”角色用户可以立即订阅该数据集，被授权的数据消费者和发布该数据集所在租户下的“Data

查看更多 →

常见问题 数据集有哪些密级 数据管理者与数据消费者的区别是什么 未发布的数据资产可以提供给数据消费者使用吗 如何发布数据集 如何订阅数据集 如何下载数据集 数据集下载成功后有哪些使用方式 修订记录

查看更多 →

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

查看更多 →

--add --allow-principal User:用户名 --consumer --topic 主题名称 --group 消费者组名称 删除某个用户的消费者权限 sh kafka-acls.sh --authorizer-properties zookeeper.connect=

查看更多 →

消息发送和消费的可靠性必须由分布式消息服务Kafka版和生产者以及消费者协同工作才能保证。同时开发者需要尽量合理使用分布式消息服务Kafka版的Topic，以提高消息发送和消息消费的效率与准确性。 对使用分布式消息服务Kafka版的生产者和消费者有如下的使用建议： 重视消息生产与消费的确认过程 消息生产

查看更多 →

附录：如何提高消息处理效率 消息生产和消费的可靠性必须由ROMA Connect、生产者和消费者协同工作才能保证，对使用ROMA Connect的生产者和消费者有如下的使用建议。 重视消息生产与消费的确认过程 消息生产 生产消息后，生产者需要根据ROMA Connect的返回信息

查看更多 →

生产者发送消息的耗时，单位ms。 地址 生产者的IP地址。 消费者状态 消费者状态如下： 消费成功 消费超时 消费异常 消费返回NULL 消费失败 消费时间 消费消息的时间。 消费耗时 消费者消费消息的耗时，单位ms。 地址 消费者的IP地址。 父主题： 管理消息

查看更多 →

导致连接断开时自动恢复连接，降低网络故障对业务的影响。 实现RabbitMQ节点重启后消费者自动重连 本章节提供了RabbitMQ节点重启后消费者自动重连示例代码，实现在通道关闭后重新为消费者创建新的通道继续消费。 提高RabbitMQ性能 本章节介绍如何通过设置队列长度、集群负

查看更多 →

设置的小一点。 如果消费者数量较多并且消息处理速度较慢，那么建议 QoS 设置为 1，让消息平均的分发到所有消费者。 请注意，如果客户端使用拉模式或者开启了自动确认（auto-ack），预拉取功能将会失效。一个常见的错误是不限制预拉取消息个数，所有消息全部发送给一个消费者，造成消费者 OOM

查看更多 →

本小节介绍如何在开发者本地进行消费者/提供者应用的开发调试。服务提供者和消费者均需要连接到在远程的服务中心，为了本地微服务的开发和调试，本小节介绍了如何启动本地服务中心。 服务中心是微服务框架中的重要组件，用于服务元数据以及服务实例元数据的管理和处理注册、发现。服务中心与微服务提供/消费者的逻辑关系下图所示：

查看更多 →

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

查看更多 →