farsunset opened a new issue #2266: URL: https://github.com/apache/rocketmq/issues/2266
4台服务集群使用同一个groupId。但是由canal发送的消息 总是被其中一台消费，其余3台基本是没有接收到过消息 MQ是用的阿里云服务，在订阅关系里面可以看到4台机器，canal机器配置如下 就是普通的消息，我们是在canal里面配置的MQ发出去的，配置如下见机密配置 消费端的GID和这里canal.mq.producerGroup配置的是同一个值GID_MQ_CANAL canal.mq.servers = xxxxxxx.cn-xxx.mq-internal.aliyuncs.com:8080 canal.mq.retries = 0 canal.mq.batchSize = 16384 canal.mq.maxRequestSize = 1048576 canal.mq.lingerMs = 100 canal.mq.bufferMemory = 33554432 canal.mq.canalBatchSize = 50 canal.mq.canalGetTimeout = 100 canal.mq.flatMessage = true canal.mq.compressionType = none canal.mq.acks = all canal.mq.properties. = canal.mq.producerGroup = GID_MQ_CANAL canal.mq.accessChannel = cloud canal.aliyun.accessKey = xxxxxxx canal.aliyun.secretKey = xxxxxxxxx canal.mq.namespace = MQ_I**_********************** canal.mq.topic= GID_MQ_CANAL_MESSAGE ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected]
