diff --git a/src/main/java/org/graylog2/inputs/mqtt/MQTTTransport.java b/src/main/java/org/graylog2/inputs/mqtt/MQTTTransport.java
index 4876ea6..311d04f 100644
--- a/src/main/java/org/graylog2/inputs/mqtt/MQTTTransport.java
+++ b/src/main/java/org/graylog2/inputs/mqtt/MQTTTransport.java
@@ -64,7 +64,7 @@ public MQTTTransport(@Assisted Configuration configuration,
         this.configuration = configuration;
         this.metricRegistry = metricRegistry;
         this.serverStatus = serverStatus;
-        this.clientId = "graylog2_" + Hashing.murmur3_32().hashUnencodedChars(this.serverStatus.getNodeId().toString()).toString();
+        this.clientId = "graylog2_" + Hashing.murmur3_32().hashUnencodedChars(this.serverStatus.getNodeId().toString() + Math.random()).toString();
     }
 
     @Override