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

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

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

查看更多 →

节点重启后消费者如何重连 本章节以Java中使用的RabbitMQ客户端amqp-client为例介绍节点重启后消费者如何重连。 amqp-client自带重连机制，但是自带的重连机制只会重试一次，一次连不上后就不会再执行了，这时如果消费者没有做额外的重试机制，那么这个消费者就彻底丧失的消费能力。

查看更多 →

Kafka生产者写入单条记录过长问题 问题背景与现象 用户在开发一个Kafka应用，作为一个生产者调用新接口（org.apache.kafka.clients.producer.*）往Kafka写数据，单条记录大小为1100055，超过了kafka配置文件server.properties中message

查看更多 →

objects 生产者列表 表4 producers 参数 参数类型 描述 producer_address String 生产者地址 broker_address String broker地址 join_time Long 加入时间 请求示例 查询Topic的当前生产者列表 GET

查看更多 →

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

查看更多 →

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

查看更多 →

分布式消息服务RocketMQ版支持任意时间的定时消息，最大推迟时间可达到1年。 定时消息即生产者生产消息到分布式消息服务RocketMQ版后，消息不会立即被消费，而是延迟到设定的时间点后才会发送给消费者进行消费。 发送定时消息前，请参考收集连接信息收集RocketMQ所需的连接信息。

查看更多 →

查看RocketMQ消费者连接地址 操作场景 分布式消息服务RocketMQ版支持通过控制台查看消费者连接地址。 消费者处于连接RocketMQ实例时，才可以查看消费者连接地址。 操作步骤 登录管理控制台。 在管理控制台左上角单击，选择区域。 请选择RocketMQ实例所在的区域。

查看更多 →

分布式消息服务RocketMQ版支持任意时间的定时消息，最大推迟时间可达到1年。 定时消息即生产者生产消息到分布式消息服务RocketMQ版后，消息不会立即被消费，而是延迟到设定的时间点后才会发送给消费者进行消费。 发送定时消息前，请参考收集连接信息收集RocketMQ所需的连接信息。 客户端连接RocketMQ实例5

查看更多 →

API配置项 表1 producer.properties文件配置项 参数 描述 备注 security.protocol 安全协议类型 生产者使用的安全协议类型，当前Kerberos开启的模式下仅支持SASL协议，需要配置为SASL_PLAINTEXT。Kerberos未开启的模式下配置为PLAINTEXT。

查看更多 →

如何获取Topic的分布信息 Kafka高可靠使用说明 使用Kafka Shell命令无法操作Kafka集群 Kafka生产者写入单条记录过长问题 Kakfa消费者读取单条记录过长问题 Kafka集群节点内多磁盘数据量占用高 Kafka连接ZooKeeper客户端时发生断链

查看更多 →

重启生产业务，使得生产者将新的消息发送到ROMA Connect实例中。 观察各消费组在原Kafka的消费进度，直到原Kafka中数据都已经被消费完毕。 将消费客户端的Kafka连接地址修改为ROMA Connect实例的消息集成MQS连接地址。 重启消费业务，使得消费者从ROMA Connect实例中消费消息。

查看更多 →

topics”的报错。 图1 消费者访问权限 处理方法： 如果业务要求所有消费者在同一个消费组内，即group.id相同，解决方法：为所有消费者授权相同的Topic访问权限。 如果消费者不需要在同一个消费组内，解决方法：修改group.id，让每个消费者单独在一个消费组内。 父主题：

查看更多 →

重启生产业务，使得生产者将新的消息发送到新Kafka实例中。 观察各消费组在原Kafka的消费进度，直到原Kafka中数据都已经被消费完毕。 将消费客户端的Kafka连接地址修改为新Kafka实例的连接地址。 重启消费业务，使得消费者从新Kafka实例中消费消息。 观察消费者是否能正常从新Kafka实例中获取数据。

查看更多 →