[ https://issues.apache.org/jira/browse/ROCKETMQ-141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15907722#comment-15907722 ]
ASF GitHub Bot commented on ROCKETMQ-141: ----------------------------------------- Github user coveralls commented on the issue: https://github.com/apache/incubator-rocketmq/pull/78 [![Coverage Status](https://coveralls.io/builds/10566542/badge)](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)