X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fpayment%2Ftransfer%2Fadapter%2FTransferConsumer.java;h=e7c2430a2d3b5c4aa4eb6a3df865033b2284b347;hb=78721edb87827a1837f298f24761af8be640c58b;hp=17d91dea868b6d9f535984a0234882e27efcbde7;hpb=4467c5240397a47b181106a0ae902ed1b71d0c5d;p=demos%2Fkafka%2Fdemos-kafka-payment-system-transfer

diff --git a/src/main/java/de/juplo/kafka/payment/transfer/adapter/TransferConsumer.java b/src/main/java/de/juplo/kafka/payment/transfer/adapter/TransferConsumer.java
index 17d91de..e7c2430 100644
--- a/src/main/java/de/juplo/kafka/payment/transfer/adapter/TransferConsumer.java
+++ b/src/main/java/de/juplo/kafka/payment/transfer/adapter/TransferConsumer.java
@@ -44,7 +44,8 @@ public class TransferConsumer implements Runnable
       try
       {
         ConsumerRecords<String, String> records = consumer.poll(Duration.ofSeconds(1));
-        log.debug("polled {} records", records.count());
+        if (records.count() > 0)
+          log.debug("polled {} records", records.count());
 
         records.forEach(record ->
         {