Merge pull request #78 from kpetremann/fix_mqtt_client_id

fix: mqttv3 does not have properties
kpetremann · Mar 31, 2024 · 81079ef · 81079ef
2 parents e8e6a59 + dad51e3
commit 81079ef
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)