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/11/12 09:21:59 UTC
[GitHub] [rocketmq] iamqq23ue opened a new issue #2423: defaultTopicQueueNums is invalid
iamqq23ue opened a new issue #2423:
URL: https://github.com/apache/rocketmq/issues/2423
My cluster has a master and a slave.
I set DefaultTopicQueueNums=32, restarted the broker, and executed the java code, but the automatically created topic only has 4 queues.
----------------------------------------------------------------
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] songxiao-hui commented on issue #2423: defaultTopicQueueNums is invalid
Posted by GitBox <gi...@apache.org>.
songxiao-hui commented on issue #2423:
URL: https://github.com/apache/rocketmq/issues/2423#issuecomment-726487815
> > it's will be compare the default topic(TBW102) config's queue num and you config topic queue num then choose the min number
>
> Thanks。I have checked TBW102, the number of queues is 32, which is the same as the defaultTopicQueueNums I set.
sry，可能上次没描述清楚，这个配置指的是producer端的配置 DefaultMQProducer. defaultTopicQueueNums 默认是4，可以通过producer.setDefaultTopicQueueNums()改变， 在broker创建新topic时，会比较TBW102的队列数(你broker端配置的) 和 DefaultMQProducer. defaultTopicQueueNums 然后取其较小者，可查看源码 TopicConfigManager#createTopicInSendMessageMethod() 方法
----------------------------------------------------------------
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] songxiao-hui commented on issue #2423: defaultTopicQueueNums is invalid
Posted by GitBox <gi...@apache.org>.
songxiao-hui commented on issue #2423:
URL: https://github.com/apache/rocketmq/issues/2423#issuecomment-726036574
it's will be compare the default topic(TBW102) config's queue num and you config topic queue num then choose the min number
----------------------------------------------------------------
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] iamqq23ue commented on issue #2423: defaultTopicQueueNums is invalid
Posted by GitBox <gi...@apache.org>.
iamqq23ue commented on issue #2423:
URL: https://github.com/apache/rocketmq/issues/2423#issuecomment-726468515
> it's will be compare the default topic(TBW102) config's queue num and you config topic queue num then choose the min number
Thanks。I have checked TBW102, the number of queues is 32, which is the same as the defaultTopicQueueNums I set.
----------------------------------------------------------------
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] iamqq23ue closed issue #2423: defaultTopicQueueNums is invalid
Posted by GitBox <gi...@apache.org>.
iamqq23ue closed issue #2423:
URL: https://github.com/apache/rocketmq/issues/2423
----------------------------------------------------------------
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] iamqq23ue commented on issue #2423: defaultTopicQueueNums is invalid
Posted by GitBox <gi...@apache.org>.
iamqq23ue commented on issue #2423:
URL: https://github.com/apache/rocketmq/issues/2423#issuecomment-725972217
> you can paste your's broker config properties
brokerClusterName=DefaultCluster
brokerName=broker-a
brokerId=0
deleteWhen=04
fileReservedTime=48
brokerRole=SYNC_MASTER
flushDiskType=SYNC_FLUSH
traceTopicEnable=true
defaultTopicQueueNums=32
----------------------------------------------------------------
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] songxiao-hui commented on issue #2423: defaultTopicQueueNums is invalid
Posted by GitBox <gi...@apache.org>.
songxiao-hui commented on issue #2423:
URL: https://github.com/apache/rocketmq/issues/2423#issuecomment-725964299
you can paste your's broker config properties
----------------------------------------------------------------
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] iamqq23ue commented on issue #2423: defaultTopicQueueNums is invalid
Posted by GitBox <gi...@apache.org>.
iamqq23ue commented on issue #2423:
URL: https://github.com/apache/rocketmq/issues/2423#issuecomment-726590880
Thanks, i get it
----------------------------------------------------------------
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