|
@@ -5,6 +5,7 @@ import java.util.concurrent.TimeoutException;
|
|
import java.util.concurrent.atomic.AtomicInteger;
|
|
import java.util.concurrent.atomic.AtomicInteger;
|
|
|
|
|
|
import com.alibaba.otter.canal.protocol.CanalEntry.EntryType;
|
|
import com.alibaba.otter.canal.protocol.CanalEntry.EntryType;
|
|
|
|
+import com.alibaba.otter.canal.sink.exception.CanalSinkException;
|
|
import com.alibaba.otter.canal.store.model.Event;
|
|
import com.alibaba.otter.canal.store.model.Event;
|
|
|
|
|
|
/**
|
|
/**
|