This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/master by this push: new bddc019 Fixed CS bddc019 is described below commit bddc019e7ae799de2550592b9bffb3ebb1c3857d Author: Andrea Cosentino <anco...@gmail.com> AuthorDate: Mon Jun 4 08:30:58 2018 +0200 Fixed CS --- .../apache/camel/component/kafka/embedded/EmbeddedKafkaBroker.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/embedded/EmbeddedKafkaBroker.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/embedded/EmbeddedKafkaBroker.java index 5dae04f..81446bb 100644 --- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/embedded/EmbeddedKafkaBroker.java +++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/embedded/EmbeddedKafkaBroker.java @@ -50,7 +50,7 @@ public class EmbeddedKafkaBroker extends ExternalResource { private KafkaServer kafkaServer; private File logDir; - private ZkUtils zkUtils = null; + private ZkUtils zkUtils; public EmbeddedKafkaBroker(int brokerId, String zkConnection) { this(brokerId, AvailablePortFinder.getNextAvailable(), zkConnection, new Properties()); @@ -95,8 +95,8 @@ public class EmbeddedKafkaBroker extends ExternalResource { private KafkaServer startBroker(Properties props) { - zkUtils = ZkUtils.apply( - zkConnection, + zkUtils = ZkUtils.apply( + zkConnection, 30000, 30000, false); -- To stop receiving notification emails like this one, please contact acosent...@apache.org.