fix: mqttv3 does not have properties

kpetremann · Mar 28, 2024 · dad51e3 · dad51e3
1 parent e8e6a59
commit dad51e3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/mqtt_exporter/main.py b/mqtt_exporter/main.py
@@ -58,7 +58,7 @@ def _create_msg_counter_metrics():
 def subscribe(client, _, __, reason_code, properties):
     """Subscribe to mqtt events (callback)."""
     user_data = {"client_id": settings.MQTT_CLIENT_ID}
-    if not settings.MQTT_CLIENT_ID:
+    if not settings.MQTT_CLIENT_ID and settings.MQTT_V5_PROTOCOL:
         user_data["client_id"] = properties.AssignedClientIdentifier
 
     client.user_data_set(user_data)