diff --git a/go.mod b/go.mod
index fcad41db4..8e0429695 100644
--- a/go.mod
+++ b/go.mod
@@ -71,7 +71,7 @@ require (
 	github.com/docker/docker v25.0.0+incompatible
 	github.com/docker/go-connections v0.5.0
 	github.com/dynatrace-oss/dynatrace-metric-utils-go v0.5.0
-	github.com/eclipse/paho.golang v0.11.0
+	github.com/eclipse/paho.golang v0.20.0
 	github.com/eclipse/paho.mqtt.golang v1.4.3
 	github.com/facebook/time v0.0.0-20240125155343-557f84f4ad3e
 	github.com/fatih/color v1.16.0
diff --git a/go.sum b/go.sum
index 9e242fbde..c805e0377 100644
--- a/go.sum
+++ b/go.sum
@@ -1090,8 +1090,8 @@ github.com/echlebek/crock v1.0.1 h1:KbzamClMIfVIkkjq/GTXf+N16KylYBpiaTitO3f1ujg=
 github.com/echlebek/crock v1.0.1/go.mod h1:/kvwHRX3ZXHj/kHWJkjXDmzzRow54EJuHtQ/PapL/HI=
 github.com/echlebek/timeproxy v1.0.0 h1:V41/v8tmmMDNMA2GrBPI45nlXb3F7+OY+nJz1BqKsCk=
 github.com/echlebek/timeproxy v1.0.0/go.mod h1:0dg2Lnb8no/jFwoMQKMTU6iAivgoMptGqSTprhnrRtk=
-github.com/eclipse/paho.golang v0.11.0 h1:6Avu5dkkCfcB61/y1vx+XrPQ0oAl4TPYtY0uw3HbQdM=
-github.com/eclipse/paho.golang v0.11.0/go.mod h1:rhrV37IEwauUyx8FHrvmXOKo+QRKng5ncoN1vJiJMcs=
+github.com/eclipse/paho.golang v0.20.0 h1:SQw/d7YhphDPkIURTQzyWK+dnS36scSVLvFbcVvNm+o=
+github.com/eclipse/paho.golang v0.20.0/go.mod h1:TSDCUivu9JnoR9Hl+H7sQMcHkejWH2/xKK1NJGtLbIE=
 github.com/eclipse/paho.mqtt.golang v1.4.3 h1:2kwcUGn8seMUfWndX0hGbvH8r7crgcJguQNCyp70xik=
 github.com/eclipse/paho.mqtt.golang v1.4.3/go.mod h1:CSYvoAlsMkhYOXh/oKyxa8EcBci6dVkLCbo5tTC1RIE=
 github.com/emicklei/go-restful/v3 v3.11.0 h1:rAQeMHw1c7zTmncogyy8VvRZwtkmkZ4FxERmMY4rD+g=
diff --git a/plugins/common/mqtt/mqtt_v5.go b/plugins/common/mqtt/mqtt_v5.go
index 4b112a7e1..ca380a776 100644
--- a/plugins/common/mqtt/mqtt_v5.go
+++ b/plugins/common/mqtt/mqtt_v5.go
@@ -30,10 +30,10 @@ func NewMQTTv5Client(cfg *MqttConfig) (*mqttv5Client, error) {
 		KeepAlive:      uint16(cfg.KeepAlive),
 		OnConnectError: cfg.OnConnectionLost,
 	}
-	opts.SetConnectPacketConfigurator(func(c *mqttv5.Connect) *mqttv5.Connect {
+	opts.ConnectPacketBuilder = func(c *mqttv5.Connect, _ *url.URL) *mqttv5.Connect {
 		c.CleanStart = cfg.PersistentSession
 		return c
-	})
+	}
 
 	if time.Duration(cfg.ConnectionTimeout) >= 1*time.Second {
 		opts.ConnectTimeout = time.Duration(cfg.ConnectionTimeout)
@@ -115,7 +115,8 @@ func (m *mqttv5Client) Connect() (bool, error) {
 		return false, fmt.Errorf("getting password failed: %w", err)
 	}
 	defer pass.Destroy()
-	m.options.SetUsernamePassword(user.TemporaryString(), pass.Bytes())
+	m.options.ConnectUsername = user.TemporaryString()
+	m.options.ConnectPassword = pass.Bytes()
 
 	client, err := mqttv5auto.NewConnection(context.Background(), m.options)
 	if err != nil {