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

Posted to commits@rocketmq.apache.org by "odbozhou (via GitHub)" <gi...@apache.org> on 2023/05/16 12:04:34 UTC

[GitHub] [rocketmq-connect] odbozhou commented on issue #505: 配置服务rocketmq实现疑问

odbozhou commented on issue #505:
URL: https://github.com/apache/rocketmq-connect/issues/505#issuecomment-1549534502

   配置变化时会向指定的配置topic（connector-config-topic）发消息
   可以看下这块实现
   org.apache.rocketmq.connect.runtime.service.AbstractConfigManagementService#putConnectorConfig
   
   所有worker都会消费connector-config-topic消息。这样所有worker就可以获取到全量的connector，task配置信息
   处理逻辑可以看下这个方法
   org.apache.rocketmq.connect.runtime.service.AbstractConfigManagementService#process


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