CreateTime：生产者创建消息的时间。 LogAppendTime：broker将消息写入日志的时间。 批处理消息最大值 Kafka允许的最大批处理大小，如果启用消息压缩，则表示压缩后的最大批处理大小。 如果增加“批处理消息最大值”的值，且存在消费者版本早于0.10.2，此时消费者的“fetch

查看更多 →

开启RabbitMQ ACL访问 通过ACL可以实现对RabbitMQ实例中生产者和消费者身份的精确识别，为不同用户赋予不同的Vhost和Vhost下不同资源的权限，以达到不同用户之间权限隔离的目的。开启ACL权限控制功能后，生产消息和消费消息时，需要鉴权。 仅RabbitMQ

查看更多 →

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

查看更多 →

x支持基于实例规格的流量控制。 支持client、user和Topic级别，通过主动设置可将流控作用于生产者或消费者。 RabbitMQ的流控基于Credit-Based算法，是内部被动触发的保护机制，作用于生产者层面。 消息顺序性 单队列（queue）内有序。 支持单分区（partition）级别的顺序性。

查看更多 →

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

查看更多 →

进行。生产者向消息主题发布消息，多个消费者订阅该消息主题的消息，生产者与消费者彼此并无直接关系。 发布区域：华北-北京一、华北-北京四、华东-上海一、华东-上海二、华南-广州、亚太-新加坡 创建Topic 命令行方式连接MQS 查询Topic消息记录 生产者与消费者 生产者为向T

查看更多 →

Artemis的技术构建而成的。ArtemisMQ提供了可靠的异步消息传递机制，允许不同的应用程序之间通过消息进行通信。它采用了基于消息的中间件模式，允许生产者（发送者）将消息发送到队列或主题，而消费者（接收者）则可以从队列或主题中接收并处理这些消息。 创建ArtemisMQ连接 登录CodeArts Link控制台。

查看更多 →

--add --allow-principal User:<用户名> --consumer --topic <Topic名称> --group <消费者组名称> bin/kafka-acls.sh --bootstrap-server <Kafka集群IP:21007> --command-config

查看更多 →

--add --allow-principal User:<用户名> --consumer --topic <Topic名称> --group <消费者组名称> bin/kafka-acls.sh --bootstrap-server <Kafka集群IP:21007> --command-config

查看更多 →

在指定Topic的“权限”列，勾选“Kafka生产者权限”。 设置用户对Topic的消费权限 在“配置资源权限”的表格中选择“待操作集群的名称 > Kafka > Kafka Topic生产和消费权限”。 在指定Topic的“权限”列，勾选“Kafka消费者权限”。 单击“确定”完成，返回“角色”。

查看更多 →

--add --allow-principal User:<用户名> --consumer --topic <Topic名称> --group <消费者组名称> shkafka-acls.sh --bootstrap-server <Kafka集群IP:21007> --command-config

查看更多 →

--add --allow-principal User:<用户名> --consumer --topic <Topic名称> --group <消费者组名称> shkafka-acls.sh --bootstrap-server <Kafka集群IP:21007> --command-config

查看更多 →

c。 消费组 表3 消费组约束与限制 限制项 约束与限制 是否需要创建消费组、消费者、生产者 “auto.create.groups.enable”为“true”时，不需要单独创建消费组、生产者和消费者，在使用时自动生成，实例创建后，直接使用即可。 “auto.create.groups

查看更多 →

x支持基于实例规格的流量控制。 支持client、user和Topic级别，通过主动设置可将流控作用于生产者或消费者。 RabbitMQ的流控基于Credit-Based算法，是内部被动触发的保护机制，作用于生产者层面。 消息顺序性 单队列（queue）内有序。 支持单分区（partition）级别的顺序性。

查看更多 →

在指定Topic的“权限”列，勾选“Kafka生产者权限”。 设置用户对Topic的消费权限 在“配置资源权限”的表格中选择“待操作集群的名称 > Kafka > Kafka Topic生产和消费权限”。 在指定Topic的“权限”列，勾选“Kafka消费者权限”。 单击“确定”完成，返回“角色”。

查看更多 →

尽量复用producer，不要频繁创建producer。当producer开启幂等时（生产者客户端3.0及之后的版本默认开启幂等），生产消息会在服务端创建生产者状态对象，若频繁创建producer，会导致服务端创建大量生产者状态对象后无法及时回收，服务端内存占用飙升，进而导致服务端性能急剧下降。

查看更多 →

频繁打开和关闭连接或通道会发送和接收大量的TCP包，从而导致更高的延迟，确保不要频繁打开和关闭连接或通道。 生产者和消费者使用不同的连接 生产者和消费者使用不同的连接以实现高吞吐量。当生产者发送太多消息给服务端处理时，RabbitMQ会将压力传递到TCP连接上。如果在同一个TCP连接上消费

查看更多 →

40% 内存使用率超过40%可能会触发内存高水位，内存高水位会导致生产者流程被阻塞。 仅RabbitMQ 3.8.35版本存在内存高水位限制。 磁盘高水位阈值 >= 5GB 磁盘剩余空间低于5GB会触发磁盘高水位，生产者流程被阻塞。 仅RabbitMQ 3.8.35版本存在磁盘高水位限制。

查看更多 →

修改配置项“spark.event.listener.logRate”，该配置项的单位为毫秒。 启动应用，可以发现如下的日志信息（消费者速率、生产者速率、当前队列中的消息数量和队列中消息数量的最大值）。 INFO LiveListenerBus: [SparkListenerBus]:16044

查看更多 →

修改配置项“spark.event.listener.logRate”，该配置项的单位为毫秒。 启动应用，可以发现如下的日志信息（消费者速率、生产者速率、当前队列中的消息数量和队列中消息数量的最大值）。 INFO LiveListenerBus: [SparkListenerBus]:16044

查看更多 →

查看RocketMQ消费者连接地址 消费者连接地址即消费消息的客户端地址，当客户端连接RocketMQ消费消息时，可通过控制台查看客户端的连接地址。 约束与限制 消费者处于连接RocketMQ实例时，才可以查看消费者连接地址。 前提条件 已创建消费组，且消费组中已存在消费者。 已创建Topic。

查看更多 →