X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2FApplicationTests.java;fp=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2FApplicationTests.java;h=05eebd0417f660e9ef3773e6de759dece1922037;hb=ee7e93b30bcee5b709ffc1631a2b0196a8194c5a;hp=39ff0d7110cac758547928f8dc77e1fceec50e25;hpb=221f774959bb0d1e113bdeefd8fdc52ea1291081;p=demos%2Fkafka%2Ftraining

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<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) ->
 				{