diff --git a/consumer_group_test.go b/consumer_group_test.go
index 2b53da4aa..2e9d180e9 100644
--- a/consumer_group_test.go
+++ b/consumer_group_test.go
@@ -40,6 +40,7 @@ func TestConsumerGroupNewSessionDuringOffsetLoad(t *testing.T) {
 	config.Consumer.Offsets.AutoCommit.Enable = false
 
 	broker0 := NewMockBroker(t, 0)
+	defer broker0.Close()
 
 	broker0.SetHandlerByMap(map[string]MockResponse{
 		"MetadataRequest": NewMockMetadataResponse(t).