Skip to content

Commit 672a68f

Browse files
committed
Add copilot feedback
1 parent 563fe37 commit 672a68f

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

kafka/adminapi_test.go

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1350,7 +1350,10 @@ func TestAdminClientLog(t *testing.T) {
13501350
t.Fatalf("Failed to create AdminClient: %v", err)
13511351
}
13521352

1353-
defer admin.Close()
1353+
defer func() {
1354+
admin.Close()
1355+
close(logsChan)
1356+
}()
13541357

13551358
expectedLogs := map[struct {
13561359
tag string

0 commit comments

Comments
 (0)