commit 5603a10611de6dc8dde5b3f0b230d1ad31422074
author kchilton2 <kevin.e.chilton@gmail.com> Tue Dec 05 17:39:55 2017 -0500
committer caleb <caleb.meier@parsons.com> Tue Jan 09 15:13:01 2018 -0500
tree c5b7db28f44a6914f7b96ac7d9966700afaa61ad
parent 2957c75a930396f86b606be8f7373dd3adcaf46c

RYA-377 Fixed a bug that made kafka integration tests fail.

test/kafka/src/main/java/org/apache/rya/test/kafka/KafkaTestUtil.java

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());