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 {