X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FEndlessConsumer.java;h=14a875b2758a9eb52fd63b8b468267df0e4276dd;hb=10ce2447023fbf9ceb9e431a97a38dd8b5f488fa;hp=be371aec1a157202185ed19268d2c6620abfdb2c;hpb=f20231dcb36eaeee69e07192b5785bc59abc1dc1;p=demos%2Fkafka%2Ftraining

diff --git a/src/main/java/de/juplo/kafka/EndlessConsumer.java b/src/main/java/de/juplo/kafka/EndlessConsumer.java
index be371ae..14a875b 100644
--- a/src/main/java/de/juplo/kafka/EndlessConsumer.java
+++ b/src/main/java/de/juplo/kafka/EndlessConsumer.java
@@ -84,7 +84,7 @@ public class EndlessConsumer implements Runnable
                   "{} - Seen {} messages for partition={}|key={}",
                   id,
                   removed.get(key),
-                  removed,
+                  tp.partition(),
                   key);
             }
           });