diff --git a/pkg/kfake/cluster.go b/pkg/kfake/cluster.go index fb622f41..e1a92969 100644 --- 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