Verwendung eines weniger verwirrenden Key in Tests (fachlich irrelevant)

[demos/kafka/training] / src / test / java / de / juplo / kafka / ApplicationTests.java

diff --git a/src/test/java/de/juplo/kafka/ApplicationTests.java b/src/test/java/de/juplo/kafka/ApplicationTests.java
index 39ff0d7..05eebd0 100644 (file)
--- 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<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) ->
                                {