Verwendung eines weniger verwirrenden Key in Tests (fachlich irrelevant)
authorKai Moritz <kai@juplo.de>
Tue, 26 Jul 2022 10:42:45 +0000 (12:42 +0200)
committerKai Moritz <kai@juplo.de>
Tue, 26 Jul 2022 10:42:45 +0000 (12:42 +0200)
src/test/java/de/juplo/kafka/ApplicationTests.java

index 39ff0d7..05eebd0 100644 (file)
@@ -206,7 +206,7 @@ class ApplicationTests
                        for (int key = 0; key < 10; key++)
                        {
                                ProducerRecord<String, Bytes> record =
-                                               recordGenerator.generate(partition, Integer.toString(key%2), ++i);
+                                               recordGenerator.generate(partition, Integer.toString(partition*10+key%2), ++i);
 
                                kafkaProducer.send(record, (metadata, e) ->
                                {