From: Kai Moritz <kai@juplo.de>
Date: Tue, 26 Jul 2022 10:42:45 +0000 (+0200)
Subject: Verwendung eines weniger verwirrenden Key in Tests (fachlich irrelevant)
X-Git-Tag: endless-stream-consumer-DEPRECATED^2^2^2~1^2~3^2~2
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=ee7e93b30bcee5b709ffc1631a2b0196a8194c5a;p=demos%2Fkafka%2Ftraining

Verwendung eines weniger verwirrenden Key in Tests (fachlich irrelevant)
---

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