From 5c373fa7d8cb7d7c1e80c8033b27dcffd26ba847 Mon Sep 17 00:00:00 2001 From: Xavi Ramirez Date: Mon, 7 Aug 2017 00:54:29 +0000 Subject: [PATCH] Fixed unit tests --- batchconsumer/writer_test.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/batchconsumer/writer_test.go b/batchconsumer/writer_test.go index 0f7e189..d62c467 100644 --- a/batchconsumer/writer_test.go +++ b/batchconsumer/writer_test.go @@ -124,9 +124,8 @@ func (m *mockCheckpointer) wait() error { func (m *mockCheckpointer) Shutdown() { m.shutdown <- struct{}{} } -func (m *mockCheckpointer) Checkpoint(pair kcl.SequencePair, retry int) error { +func (m *mockCheckpointer) Checkpoint(pair kcl.SequencePair) { m.checkpoint <- pair.Sequence.String() - return nil } func encode(str string) string {