diff --git a/test/kafka/src/main/java/org/apache/rya/test/kafka/KafkaTestUtil.java b/test/kafka/src/main/java/org/apache/rya/test/kafka/KafkaTestUtil.java
index 4b41f1a..fa1e0a0 100644
--- a/test/kafka/src/main/java/org/apache/rya/test/kafka/KafkaTestUtil.java
+++ b/test/kafka/src/main/java/org/apache/rya/test/kafka/KafkaTestUtil.java
@@ -87,6 +87,7 @@
 
         final Properties props = kafka.createBootstrapServerConfig();
         props.setProperty(ConsumerConfig.GROUP_ID_CONFIG, UUID.randomUUID().toString());
+        props.setProperty(ConsumerConfig.CLIENT_ID_CONFIG, UUID.randomUUID().toString());
         props.setProperty(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");
         props.setProperty(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, keyDeserializerClass.getName());
         props.setProperty(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, valueDeserializerClass.getName());