GRÜN: Implementierung der Erwartungen inkl. Anpassungen an der Anwendung

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

diff --git a/src/main/java/de/juplo/kafka/ApplicationRebalanceListener.java b/src/main/java/de/juplo/kafka/ApplicationRebalanceListener.java
index 542af2d..5a01393 100644 (file)
--- a/src/main/java/de/juplo/kafka/ApplicationRebalanceListener.java
+++ b/src/main/java/de/juplo/kafka/ApplicationRebalanceListener.java
@@ -62,7 +62,7 @@ public class ApplicationRebalanceListener implements PollIntervalAwareConsumerRe
           offset);
       if (commitsEnabled)
       {
-        Map<String, Long> removed = recordHandler.removePartition(partition);
+        Map<String, AdderResult> removed = recordHandler.removePartition(partition);
         stateRepository.save(new StateDocument(partition, removed, offset));
       }
       else