Rückbau auf verschachtelte Maps

[demos/kafka/training] / src / main / java / de / juplo / kafka / EndlessConsumer.java

diff --git a/src/main/java/de/juplo/kafka/EndlessConsumer.java b/src/main/java/de/juplo/kafka/EndlessConsumer.java
index be371ae..14a875b 100644 (file)
--- 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);
             }
           });