You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by "leehom (via GitHub)" <gi...@apache.org> on 2023/05/16 10:53:17 UTC
[GitHub] [rocketmq-connect] leehom opened a new issue, #506: 配置服务rocketmq实现的疑问
leehom opened a new issue, #506:
URL: https://github.com/apache/rocketmq-connect/issues/506
配置服务的rocketmq实现start并没有发出START_SIGNAL，获取其他worker的配置，local实现是有的，rocketmq实现不支持新worker负载均衡？
--
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.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq-connect] leehom commented on issue #506: 配置服务rocketmq实现的疑问
Posted by "leehom (via GitHub)" <gi...@apache.org>.
leehom commented on issue #506:
URL: https://github.com/apache/rocketmq-connect/issues/506#issuecomment-1550586986
> > ClusterManagementServiceImpl
>
> ClusterManagementServiceImpl成员变更发现，然后就重分派，新的worker需要知道全量的连接器和任务配置，local实现通过发送START_SIGNAL，获取其他worker的配置，但rocketmq实现并没有，不知道怎么获取全量的连接器和任务配置
位点也有同样的问题，位点的local实现ONLINE的事件进行新旧worker 偏移的同步，rocketmq没有
--
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
[GitHub] [rocketmq-connect] sunxiaojian commented on issue #506: 配置服务rocketmq实现的疑问
Posted by "sunxiaojian (via GitHub)" <gi...@apache.org>.
sunxiaojian commented on issue #506:
URL: https://github.com/apache/rocketmq-connect/issues/506#issuecomment-1558380074
rocketmq是为 rocketmq compact topic准备的，用的是一个topic 存储的，不需要进行通知，监听compact就行了
--
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
[GitHub] [rocketmq-connect] leehom closed issue #506: 配置服务rocketmq实现的疑问
Posted by "leehom (via GitHub)" <gi...@apache.org>.
leehom closed issue #506: 配置服务rocketmq实现的疑问
URL: https://github.com/apache/rocketmq-connect/issues/506
--
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
[GitHub] [rocketmq-connect] leehom commented on issue #506: 配置服务rocketmq实现的疑问
Posted by "leehom (via GitHub)" <gi...@apache.org>.
leehom commented on issue #506:
URL: https://github.com/apache/rocketmq-connect/issues/506#issuecomment-1550585915
> ClusterManagementServiceImpl
ClusterManagementServiceImpl成员变更发现，然后就重分派，新的worker需要知道全量的连接器和任务配置，local实现通过发送START_SIGNAL，获取其他worker的配置，但rocketmq实现并没有，不知道怎么获取全量的连接器和任务配置
--
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
[GitHub] [rocketmq-connect] odbozhou commented on issue #506: 配置服务rocketmq实现的疑问
Posted by "odbozhou (via GitHub)" <gi...@apache.org>.
odbozhou commented on issue #506:
URL: https://github.com/apache/rocketmq-connect/issues/506#issuecomment-1549538163
新增或者建设worker都是支持的，可以看下这块逻辑，
org.apache.rocketmq.connect.runtime.service.ClusterManagementServiceImpl#start
利用rocketmq PullConsumer 监听机制实现worker的服务发现
--
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