WIP

[demos/kafka/training] / src / test / java / de / juplo / kafka / ApplicationTests.java

diff --git a/src/test/java/de/juplo/kafka/ApplicationTests.java b/src/test/java/de/juplo/kafka/ApplicationTests.java
index 09614b8..f19bfb1 100644 (file)
--- a/src/test/java/de/juplo/kafka/ApplicationTests.java
+++ b/src/test/java/de/juplo/kafka/ApplicationTests.java
@@ -156,10 +156,10 @@ class ApplicationTests
                        Long offset = offsetConsumer.position(tp);
                        log.info("New position for {}: {}", tp, offset);
                        Integer partition = tp.partition();
-                       StatisticsDocument document =
+                       StateDocument document =
                                        partitionStatisticsRepository
                                                        .findById(partition.toString())
-                                                       .orElse(new StatisticsDocument(partition));
+                                                       .orElse(new StateDocument(partition));
                        document.offset = offset;
                        partitionStatisticsRepository.save(document);
                });