diff --git a/instance/manager/src/main/java/com/alibaba/otter/canal/instance/manager/CanalInstanceWithManager.java b/instance/manager/src/main/java/com/alibaba/otter/canal/instance/manager/CanalInstanceWithManager.java index 9005c73d..4fdf374e 100644 --- a/instance/manager/src/main/java/com/alibaba/otter/canal/instance/manager/CanalInstanceWithManager.java +++ b/instance/manager/src/main/java/com/alibaba/otter/canal/instance/manager/CanalInstanceWithManager.java @@ -65,15 +65,15 @@ import com.alibaba.otter.canal.store.model.Event; public class CanalInstanceWithManager extends AbstractCanalInstance { private static final Logger logger = LoggerFactory.getLogger(CanalInstanceWithManager.class); - protected String destination; // 队列名字 + //protected String destination; // 队列名字 protected String filter; // 过滤表达式 protected CanalParameter parameters; // 对应参数 - protected CanalMetaManager metaManager; // 消费信息管理器 - protected CanalEventStore eventStore; // 有序队列 + //protected CanalMetaManager metaManager; // 消费信息管理器 + //protected CanalEventStore eventStore; // 有序队列 - protected CanalEventParser eventParser; // 解析对应的数据信息 - protected CanalEventSink> eventSink; // 链接parse和store的桥接器 - protected CanalAlarmHandler alarmHandler; // alarm报警机制 + //protected CanalEventParser eventParser; // 解析对应的数据信息 + //protected CanalEventSink> eventSink; // 链接parse和store的桥接器 + //protected CanalAlarmHandler alarmHandler; // alarm报警机制 public CanalInstanceWithManager(Canal canal, String filter){ this.parameters = canal.getCanalParameter();