[
https://issues.apache.org/jira/browse/ROCKETMQ-141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15907721#comment-15907721
]
ASF GitHub Bot commented on ROCKETMQ-141:
-----------------------------------------
Github user coveralls commented on the issue:
https://github.com/apache/incubator-rocketmq/pull/78
[](https://coveralls.io/builds/10566542)
Coverage decreased (-0.01%) to 30.994% when pulling
**51de91c4bddb401eba4fa10e93f85555c75a8997 on lizhanhui:ROCKETMQ-141** into
**d7decc84abc32dab63ee423d4d904f28d18cb1d7 on apache:develop**.
> Make producers establish connection eagerly to new joined brokers
> -----------------------------------------------------------------
>
> Key: ROCKETMQ-141
> URL: https://issues.apache.org/jira/browse/ROCKETMQ-141
> Project: Apache RocketMQ
> Issue Type: Improvement
> Components: rocketmq-client
> Affects Versions: 4.1.0-incubating
> Reporter: Zhanhui Li
> Assignee: Zhanhui Li
>
> When new brokers joins the cluster, MQ producer clients polls name server and
> add the new-joined brokers to topicPublishInfo in case the new-joined broker
> bears the topic. Later on, the producers may send messages to the new-joined
> brokers.
> This achieves part of scalable goals and works fine for most cases. However,
> we ran an issue in this process. The problem is when new broker joins the
> cluster, the producer clients blocks for quite a while even if when
> asynchronous send method is employed, which is very miserable for latency
> sensitive scenarios.
> After analyzing the root cause, it turns out that producer clients need to
> establish a connection to the new-joined brokers the first time it sends a
> message, as is blocking.
> This issue is to establish a connection to new-joined brokers immediately
> after polling name server and make them available to send methods thereafter.
> Thus, when send is called against new-joined brokers, there is a writable
> channel readily available.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
