bvn13/kafka-health-check
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Change logging level

Browse Source
This commit is contained in:
Emanuel Zienecker 2019-09-10 10:45:21 +02:00
parent 23e0a6b39c
commit 0b390fe9dd
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/com/deviceinsight/kafka/health/KafkaConsumingHealthIndicator.java
View File

@ -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);