org.apache.rocketmq.client.impl.factory.MQClientInstance#LOCK_TIMEOUT_MILLIS is too small

apache / rocketmq

Apache RocketMQ is a cloud native messaging and streaming platform, making it simple to build event-driven applications.

https://rocketmq.apache.org/

Apache License 2.0

21.19k stars 11.67k forks source link

org.apache.rocketmq.client.impl.factory.MQClientInstance#LOCK_TIMEOUT_MILLIS is too small #2068

Closed manfrid closed 2 years ago

manfrid commented 4 years ago

我的程序启动的时候，线程很多，都发message。获取TopicRouteInfo的时候，在执行到 org.apache.rocketmq.client.impl.factory.MQClientInstance#updateTopicRouteInfoFromNameServer(java.lang.String, boolean, org.apache.rocketmq.client.producer.DefaultMQProducer) 的时候，都去排队等待获取TopicRouteInfo。很多会获取锁超时

能否灵活的这个参数设置成可以设置的

imaffe commented 4 years ago

This parameter is defined as static final and hardcoded in source code in TopicConfigManager. Would be nice if you wish to help making this timeout configurable. However we are not sure if this aligns with our current configuration diagram. If we currently don't support configuring XXXManager, we might need to create a RIP to update all the hard-coded configuration to stay consistent.

github-actions[bot] commented 2 years ago

This issue is stale because it has been open for 365 days with no activity. It will be closed in 3 days if no further activity occurs.

github-actions[bot] commented 2 years ago

This issue was closed because it has been inactive for 3 days since being marked as stale.