开发者社区 问答 正文

OtterSelectorFactory 没有重用 CanalServerWithEmbedded对

otter/node/etl/src/main/java/com/alibaba/otter/node/etl/select/selector/OtterSelectorFactory.java

Lines 28 to 36 in dce2471

public class OtterSelectorFactory {

 public OtterSelector getSelector(Long pipelineId) { 
     CanalEmbedSelector selector = new CanalEmbedSelector(pipelineId); 
     OtterContextLocator.autowire(selector); 
     return selector; 
 } 

} CanalServerWithEmbedded 支持多个数据队列,应该使用CanalServerWithEmbedded.instance()单例方法减少内存占用。

原提问者GitHub用户JerryChin

展开
收起
古拉古拉 2023-06-16 20:48:26 69 分享 版权
1 条回答
写回答
取消 提交回答
  • otter的pipeline链路会有重启的情况, 独立的canalserver instance, 互相干扰的成分少

    原回答者GitHub用户agapple

    2023-06-16 21:35:46
    赞同 展开评论
问答分类:
问答地址: