You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@rocketmq.apache.org by "francisoliverlee (via GitHub)" <gi...@apache.org> on 2023/02/21 07:30:01 UTC

[GitHub] [rocketmq-client-go] francisoliverlee commented on issue #1007: Trace topic's routeInfoData can never be updated

francisoliverlee commented on issue #1007:
URL: https://github.com/apache/rocketmq-client-go/issues/1007#issuecomment-1437976519

   我发现路由自动更新的逻辑是有的， 可以试试是否生效。
   主要的处理过程如下：
   1. 初始化rmqClient，维护一个producerMap，
   https://github.com/apache/rocketmq-client-go/blob/c8d06a661a022097445cc7979290733a2cc86804/internal/client.go#L172
   启动更新topic路由的TimeTicker
   https://github.com/apache/rocketmq-client-go/blob/c8d06a661a022097445cc7979290733a2cc86804/internal/client.go#L416-L438
   2. 第一次发送消息前，获取topic已存在的路由，如果不存在则从namesrv拉取，并且调用UpdatePublishInfo()保存到对应的producer中。
   3. 正常发送消息
   


-- 
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.

To unsubscribe, e-mail: commits-unsubscribe@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org