Merge branch 'release/1.2.0'

This commit is contained in:
Emanuel Zienecker 2019-09-10 11:58:00 +02:00
commit e1a88172e4
4 changed files with 7 additions and 5 deletions

View File

@ -13,3 +13,5 @@ cache:
install: /bin/true install: /bin/true
script: ./mvnw verify -B script: ./mvnw verify -B
dist: trusty

View File

@ -16,7 +16,7 @@ Add the following dependency to your `pom.xml`
<dependency> <dependency>
<groupId>com.deviceinsight.kafka</groupId> <groupId>com.deviceinsight.kafka</groupId>
<artifactId>kafka-health-check</artifactId> <artifactId>kafka-health-check</artifactId>
<version>1.0.0</version> <version>1.1.0</version>
</dependency> </dependency>
.... ....
@ -53,8 +53,8 @@ public KafkaHealthProperties kafkaHealthProperties() {
@Bean @Bean
public KafkaConsumingHealthIndicator kafkaConsumingHealthIndicator(KafkaHealthProperties kafkaProperties, public KafkaConsumingHealthIndicator kafkaConsumingHealthIndicator(KafkaHealthProperties kafkaProperties,
KafkaProperties processingProperties) { KafkaProperties processingProperties) {
return new KafkaConsumingHealthIndicator(kafkaHealthProperties, kafkaProperties.buildConsumerProperties(), return new KafkaConsumingHealthIndicator(kafkaHealthProperties, processingProperties.buildConsumerProperties(),
kafkaProperties.buildProducerProperties()); processingProperties.buildProducerProperties());
} }
.... ....

View File

@ -6,7 +6,7 @@
<groupId>com.deviceinsight.kafka</groupId> <groupId>com.deviceinsight.kafka</groupId>
<artifactId>kafka-health-check</artifactId> <artifactId>kafka-health-check</artifactId>
<version>1.1.0</version> <version>1.2.0</version>
<packaging>jar</packaging> <packaging>jar</packaging>
<name>Kafka Health Check</name> <name>Kafka Health Check</name>

View File

@ -175,7 +175,7 @@ public class KafkaConsumingHealthIndicator extends AbstractHealthIndicator {
String message = UUID.randomUUID().toString(); 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); producer.send(new ProducerRecord<>(topic, message, message)).get(sendReceiveTimeoutMs, MILLISECONDS);