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