X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2FApplicationTests.java;fp=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2FApplicationTests.java;h=f19bfb157cc0a942a742a736b1d718ca33b89f3c;hb=5f35354fd694f78599d66ee9e01fb4c0d89cc5bb;hp=09614b8e23702f729214dd33bc7820ad3c83208d;hpb=c808810e9e33afe33b29f7fd3921023ecd15483d;p=demos%2Fkafka%2Ftraining

diff --git a/src/test/java/de/juplo/kafka/ApplicationTests.java b/src/test/java/de/juplo/kafka/ApplicationTests.java
index 09614b8..f19bfb1 100644
--- 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);
 		});