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

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 ->
         {