X-Git-Url: https://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=9dda0798d6ab70da75ae16f5d36633ad6f423a87;hb=d576eea9bc9208d9e5003bd8c8c132bed96b5c40;hp=4ddf8a909c509a336180aaa670f4e54dda06b084;hpb=0cd07d4498de934aefece33e20eee0df684e62e5;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 4ddf8a9..9dda079 100644
--- a/src/test/java/de/juplo/kafka/ApplicationTests.java
+++ b/src/test/java/de/juplo/kafka/ApplicationTests.java
@@ -22,8 +22,7 @@ public class ApplicationTests extends GenericApplicationTests<String, String>
                   .mapToObj(i -> "seeräuber-" + i)
                   .toArray(i -> new String[i]);
           final StringSerializer stringSerializer = new StringSerializer();
-          final Bytes startMessage = new Bytes(stringSerializer.serialize(TOPIC, "START"));
-          final Bytes endMessage = new Bytes(stringSerializer.serialize(TOPIC, "END"));
+          final Bytes calculateMessage = new Bytes(stringSerializer.serialize(TOPIC, "CALCULATE"));
 
           int counter = 0;
 
@@ -43,13 +42,12 @@ public class ApplicationTests extends GenericApplicationTests<String, String>
 
               Bytes key = new Bytes(stringSerializer.serialize(TOPIC, seeräuber));
 
-              send(key, startMessage, logicErrors, messageSender);
               for (int message = 1; message <= number; message++)
               {
                 Bytes value = new Bytes(stringSerializer.serialize(TOPIC, Integer.toString(message)));
                 send(key, value, logicErrors, messageSender);
               }
-              send(key, endMessage, logicErrors, messageSender);
+              send(key, calculateMessage, logicErrors, messageSender);
             }
 
             return counter;
@@ -67,7 +65,7 @@ public class ApplicationTests extends GenericApplicationTests<String, String>
             {
               if (logicErrors)
               {
-                value = value.equals(startMessage) ? endMessage : startMessage;
+                value = new Bytes(stringSerializer.serialize(TOPIC, Integer.toString(-1)));
               }
             }