diff --git a/pkg/channels/mqtt/mqtt.go b/pkg/channels/mqtt/mqtt.go
index 39956ed9c..c34bc79bf 100644
--- a/pkg/channels/mqtt/mqtt.go
+++ b/pkg/channels/mqtt/mqtt.go
@@ -213,7 +213,7 @@ func (c *MQTTChannel) Stop(_ context.Context) error {
 	logger.InfoC("mqtt", "Stopping MQTT channel")
 	c.SetRunning(false)
 
-	if c.client != nil && c.client.IsConnected() {
+	if c.client != nil {
 		c.client.Disconnect(500)
 	}