From: Kai Moritz <kai@juplo.de>
Date: Sun, 15 Dec 2024 11:03:17 +0000 (+0100)
Subject: Der Payload einer Nachricht wird über alle Nachrichten hochgezählt
X-Git-Url: https://juplo.de/gitweb/?a=commitdiff_plain;h=463a89fd30b04e8a079f33fab7bd9a9cd3252d7e;p=demos%2Fkafka%2Ftraining

Der Payload einer Nachricht wird über alle Nachrichten hochgezählt
---

diff --git a/src/test/java/de/juplo/kafka/ExampleConsumerTest.java b/src/test/java/de/juplo/kafka/ExampleConsumerTest.java
index 65254e04..9b787abc 100644
--- a/src/test/java/de/juplo/kafka/ExampleConsumerTest.java
+++ b/src/test/java/de/juplo/kafka/ExampleConsumerTest.java
@@ -148,6 +148,7 @@ public class ExampleConsumerTest
 
   LongSerializer serializer = new LongSerializer();
   long[] currentOffsets = new long[] { 0, 0 };
+  long nextMessage = 1;
 
   @Autowired
   AdminClient adminClient;
@@ -162,6 +163,7 @@ public class ExampleConsumerTest
     adminClient.deleteRecords(Map.of(
       new TopicPartition(TOPIC, 0), deleteAllRecordsByPartition(0),
       new TopicPartition(TOPIC, 1), deleteAllRecordsByPartition(1)));
+    nextMessage = 1;
     mockHandler.clear();
     isTerminatedExceptionally.set(false);
   }
@@ -173,7 +175,7 @@ public class ExampleConsumerTest
 
   private void sendValidMessage(int partition)
   {
-    send(partition, partition);
+    send(partition, nextMessage);
   }
 
   private void sendNonDeserializableMessage(int partition)
@@ -193,6 +195,7 @@ public class ExampleConsumerTest
 
   private void send(int partition, byte[] bytes)
   {
+    nextMessage++;
     kafkaTemplate.send(TOPIC, partition, "EGAL", bytes);
   }