diff --git a/internal/controller/acl/acl.go b/internal/controller/acl/acl.go index f3b0fd3..fdd16e3 100644 --- a/internal/controller/acl/acl.go +++ b/internal/controller/acl/acl.go @@ -125,7 +125,10 @@ func (c *connectDisconnector) Connect(ctx context.Context, mg resource.Managed) } func (c *connectDisconnector) Disconnect(ctx context.Context) error { - c.cachedClient.Close() + if c.cachedClient != nil { + c.cachedClient.Close() + } + c.cachedClient = nil return nil } diff --git a/internal/controller/topic/topic.go b/internal/controller/topic/topic.go index a1e781e..eaa4a10 100644 --- a/internal/controller/topic/topic.go +++ b/internal/controller/topic/topic.go @@ -121,7 +121,10 @@ func (c *connectDisconnector) Connect(ctx context.Context, mg resource.Managed) } func (c *connectDisconnector) Disconnect(ctx context.Context) error { - c.cachedClient.Close() + if c.cachedClient != nil { + c.cachedClient.Close() + } + c.cachedClient = nil return nil }