WIP producer/fencing
authorKai Moritz <kai@juplo.de>
Wed, 24 Jan 2024 22:35:46 +0000 (23:35 +0100)
committerKai Moritz <kai@juplo.de>
Wed, 24 Jan 2024 22:35:46 +0000 (23:35 +0100)
src/test/java/de/juplo/kafka/ApplicationTests.java

index 581658e..6888d1f 100644 (file)
@@ -39,8 +39,8 @@ public class ApplicationTests
     SimpleProducer instanceA = new SimpleProducer(
       bootstrapServers,
       TOPIC,
     SimpleProducer instanceA = new SimpleProducer(
       bootstrapServers,
       TOPIC,
-      "FOO",
-      "A");
+      "A",
+      "FOO");
 
     instanceA.begin();
     CompletableFuture<Long> resultA1 = instanceA.send("a","message #1");
 
     instanceA.begin();
     CompletableFuture<Long> resultA1 = instanceA.send("a","message #1");
@@ -52,8 +52,8 @@ public class ApplicationTests
     SimpleProducer instanceB = new SimpleProducer(
       bootstrapServers,
       TOPIC,
     SimpleProducer instanceB = new SimpleProducer(
       bootstrapServers,
       TOPIC,
-      "FOO",
-      "B");
+      "B",
+      "FOO");
 
     instanceB.begin();
     CompletableFuture<Long> resultB1 = instanceB.send("b","message #1");
 
     instanceB.begin();
     CompletableFuture<Long> resultB1 = instanceB.send("b","message #1");