From a53ff723dee9c17e664c7c327760029e7582eb06 Mon Sep 17 00:00:00 2001 From: Evan Huus Date: Mon, 27 Jul 2015 17:16:47 -0400 Subject: [PATCH] Fix minor test --- consumer_test.go | 1 + 1 file changed, 1 insertion(+) diff --git a/consumer_test.go b/consumer_test.go index cad709b537..6617f149e1 100644 --- a/consumer_test.go +++ b/consumer_test.go @@ -390,6 +390,7 @@ func TestConsumerInterleavedClose(t *testing.T) { fetchResponse.AddMessage("my_topic", 0, nil, ByteEncoder([]byte{0x00, 0x0E}), int64(1)) fetchResponse.AddMessage("my_topic", 1, nil, ByteEncoder([]byte{0x00, 0x0E}), int64(0)) leader.Returns(fetchResponse) + leader.Returns(fetchResponse) safeClose(t, c1) safeClose(t, c0)