From ee7e93b30bcee5b709ffc1631a2b0196a8194c5a Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Tue, 26 Jul 2022 12:42:45 +0200 Subject: [PATCH] Verwendung eines weniger verwirrenden Key in Tests (fachlich irrelevant) --- src/test/java/de/juplo/kafka/ApplicationTests.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/test/java/de/juplo/kafka/ApplicationTests.java b/src/test/java/de/juplo/kafka/ApplicationTests.java index 39ff0d7..05eebd0 100644 --- a/src/test/java/de/juplo/kafka/ApplicationTests.java +++ b/src/test/java/de/juplo/kafka/ApplicationTests.java @@ -206,7 +206,7 @@ class ApplicationTests for (int key = 0; key < 10; key++) { ProducerRecord record = - recordGenerator.generate(partition, Integer.toString(key%2), ++i); + recordGenerator.generate(partition, Integer.toString(partition*10+key%2), ++i); kafkaProducer.send(record, (metadata, e) -> { -- 2.20.1