You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2020/08/26 01:40:51 UTC
[GitHub] [rocketmq] farsunset opened a new issue #2266: 通过社区版本MQ客户端向阿里云MQ服务发消息,存在消费端消费极其不均匀的问题
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:
users@infra.apache.org
[GitHub] [rocketmq] farsunset commented on issue #2266: Uneven consumption on the consumer side
Posted by GitBox <gi...@apache.org>.
farsunset commented on issue #2266:
URL: https://github.com/apache/rocketmq/issues/2266#issuecomment-683664926
> 用的是java的客户端吗？重平衡算法是什么？重平衡后的每台机器被分配到的队列可以通过日志查看到吗？
是java客户端 版本4.5 其实是通过canal 发的MQ，配置参数
#canal.mq.partition=1
canal.mq.partitionsNum=4
canal.mq.partitionHash=.\..:id
我提了issues，他们说让我在rocketMQ社区问
----------------------------------------------------------------
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:
users@infra.apache.org
[GitHub] [rocketmq] RongtongJin commented on issue #2266: Uneven consumption on the consumer side
Posted by GitBox <gi...@apache.org>.
RongtongJin commented on issue #2266:
URL: https://github.com/apache/rocketmq/issues/2266#issuecomment-682386474
用的是java的客户端吗？重平衡算法是什么？重平衡后的每台机器被分配到的队列可以通过日志查看到吗？
----------------------------------------------------------------
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:
users@infra.apache.org
[GitHub] [rocketmq] farsunset removed a comment on issue #2266: Uneven consumption on the consumer side
Posted by GitBox <gi...@apache.org>.
farsunset removed a comment on issue #2266:
URL: https://github.com/apache/rocketmq/issues/2266#issuecomment-683664810
是java客户端 版本4.5 其实是通过canal 发的MQ，配置参数
#canal.mq.partition=1
canal.mq.partitionsNum=4
canal.mq.partitionHash=.*\\..*:id
我提了issues，他们说让我在rocketMQ社区问
----------------------------------------------------------------
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:
users@infra.apache.org
[GitHub] [rocketmq] farsunset commented on issue #2266: Uneven consumption on the consumer side
Posted by GitBox <gi...@apache.org>.
farsunset commented on issue #2266:
URL: https://github.com/apache/rocketmq/issues/2266#issuecomment-683664810
是java客户端 版本4.5 其实是通过canal 发的MQ，配置参数
#canal.mq.partition=1
canal.mq.partitionsNum=4
canal.mq.partitionHash=.*\\..*:id
我提了issues，他们说让我在rocketMQ社区问
----------------------------------------------------------------
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:
users@infra.apache.org