Merge pull request #661 from twmb/kfake_panic

kfake: do not return early when running control functions if the cluster is closed
twmb · Jan 14, 2024 · ee1f011 · ee1f011
2 parents c69fa0b + d9c8468
commit ee1f011
Showing 1 changed file with 0 additions and 4 deletions.
diff --git a/pkg/kfake/cluster.go b/pkg/kfake/cluster.go
@@ -310,8 +310,6 @@ outer:
 		inner:
 			for {
 				select {
-				case <-c.die:
-					return
 				case admin := <-c.adminCh:
 					admin()
 					continue inner
@@ -604,8 +602,6 @@ func (c *Cluster) tryControlKey(key int16, creq *clientReq) (kmsg.Response, erro
 		res := c.runControl(cctx, creq)
 		for {
 			select {
-			case <-c.die:
-				return nil, nil, false
 			case admin := <-c.adminCh:
 				admin()
 				continue