RYA-377 Fixed a bug that made kafka integration tests fail.
Project: http://git-wip-us.apache.org/repos/asf/incubator-rya/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-rya/commit/5603a106 Tree: http://git-wip-us.apache.org/repos/asf/incubator-rya/tree/5603a106 Diff: http://git-wip-us.apache.org/repos/asf/incubator-rya/diff/5603a106 Branch: refs/heads/master Commit: 5603a10611de6dc8dde5b3f0b230d1ad31422074 Parents: 2957c75 Author: kchilton2 <kevin.e.chil...@gmail.com> Authored: Tue Dec 5 17:39:55 2017 -0500 Committer: caleb <caleb.me...@parsons.com> Committed: Tue Jan 9 15:13:01 2018 -0500 ---------------------------------------------------------------------- .../src/main/java/org/apache/rya/test/kafka/KafkaTestUtil.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/5603a106/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 @@ public final class KafkaTestUtil { 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());
