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 <[email protected]>
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
[email protected].
