From f04e742f4f1f88360d20819b0005f560524d3b99 Mon Sep 17 00:00:00 2001 From: Li Qiang Date: Thu, 27 Jun 2019 09:58:24 +0800 Subject: [PATCH] #1897 , fix DummyEventStore implements new method (#1932) --- .../otter/canal/parse/inbound/group/DummyEventStore.java | 4 ++++ .../com/alibaba/otter/canal/sink/stub/DummyEventStore.java | 4 ++++ 2 files changed, 8 insertions(+) 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; }