diff --git a/.travis.yml b/.travis.yml index 64632df..26abf7b 100644 --- a/.travis.yml +++ b/.travis.yml @@ -13,3 +13,5 @@ cache: install: /bin/true script: ./mvnw verify -B + +dist: trusty diff --git a/README.adoc b/README.adoc index 92aa8e6..e41b454 100644 --- a/README.adoc +++ b/README.adoc @@ -16,7 +16,7 @@ Add the following dependency to your `pom.xml` com.deviceinsight.kafka kafka-health-check - 1.0.0 + 1.1.0 .... @@ -53,8 +53,8 @@ public KafkaHealthProperties kafkaHealthProperties() { @Bean public KafkaConsumingHealthIndicator kafkaConsumingHealthIndicator(KafkaHealthProperties kafkaProperties, KafkaProperties processingProperties) { - return new KafkaConsumingHealthIndicator(kafkaHealthProperties, kafkaProperties.buildConsumerProperties(), - kafkaProperties.buildProducerProperties()); + return new KafkaConsumingHealthIndicator(kafkaHealthProperties, processingProperties.buildConsumerProperties(), + processingProperties.buildProducerProperties()); } .... diff --git a/pom.xml b/pom.xml index f1c05cd..3265065 100644 --- a/pom.xml +++ b/pom.xml @@ -6,7 +6,7 @@ com.deviceinsight.kafka kafka-health-check - 1.1.0 + 1.2.0 jar Kafka Health Check diff --git a/src/main/java/com/deviceinsight/kafka/health/KafkaConsumingHealthIndicator.java b/src/main/java/com/deviceinsight/kafka/health/KafkaConsumingHealthIndicator.java index 80dcaa8..960382a 100644 --- a/src/main/java/com/deviceinsight/kafka/health/KafkaConsumingHealthIndicator.java +++ b/src/main/java/com/deviceinsight/kafka/health/KafkaConsumingHealthIndicator.java @@ -175,7 +175,7 @@ public class KafkaConsumingHealthIndicator extends AbstractHealthIndicator { String message = UUID.randomUUID().toString(); - logger.debug("Send health check message = {}", message); + logger.trace("Send health check message = {}", message); producer.send(new ProducerRecord<>(topic, message, message)).get(sendReceiveTimeoutMs, MILLISECONDS);