adds new method to consumer mock.

fgeller · Mar 20, 2017 · 9b0d9d8 · 9b0d9d8
1 parent 7e7c863
commit 9b0d9d8
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/consume_test.go b/consume_test.go
@@ -513,6 +513,10 @@ func (c tConsumer) Close() error {
 	return c.closeErr
 }
 
+func (c tConsumer) HighWaterMarks() map[string]map[int32]int64 {
+	return nil
+}
+
 func TestConsumeParseArgs(t *testing.T) {
 	topic := "test-topic"
 	givenBroker := "hans:9092"