From 463a89fd30b04e8a079f33fab7bd9a9cd3252d7e Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Sun, 15 Dec 2024 12:03:17 +0100 Subject: [PATCH] =?utf8?q?Der=20Payload=20einer=20Nachricht=20wird=20?= =?utf8?q?=C3=BCber=20alle=20Nachrichten=20hochgez=C3=A4hlt?= MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit --- src/test/java/de/juplo/kafka/ExampleConsumerTest.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) 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); } -- 2.20.1