Fix minor test

IBM · Jul 27, 2015 · a53ff72 · a53ff72
1 parent ee12af3
commit a53ff72
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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)