diff --git a/parse/src/test/java/com/alibaba/otter/canal/parse/inbound/group/DummyEventStore.java b/parse/src/test/java/com/alibaba/otter/canal/parse/inbound/group/DummyEventStore.java index c542e5c0..d29921f1 100644 --- a/parse/src/test/java/com/alibaba/otter/canal/parse/inbound/group/DummyEventStore.java +++ b/parse/src/test/java/com/alibaba/otter/canal/parse/inbound/group/DummyEventStore.java @@ -23,6 +23,10 @@ public class DummyEventStore implements CanalEventStore { } + public void ack(Position position, Long seqId) throws CanalStoreException { + + } + public Events get(Position start, int batchSize) throws InterruptedException, CanalStoreException { return null; } diff --git a/sink/src/test/java/com/alibaba/otter/canal/sink/stub/DummyEventStore.java b/sink/src/test/java/com/alibaba/otter/canal/sink/stub/DummyEventStore.java index 7f786ef2..d97f08a0 100644 --- a/sink/src/test/java/com/alibaba/otter/canal/sink/stub/DummyEventStore.java +++ b/sink/src/test/java/com/alibaba/otter/canal/sink/stub/DummyEventStore.java @@ -15,6 +15,10 @@ public class DummyEventStore implements CanalEventStore { } + public void ack(Position position, Long seqId) throws CanalStoreException { + + } + public Events get(Position start, int batchSize) throws InterruptedException, CanalStoreException { return null; }