From 0f373a70aeaf65767c5354ca7e0944617c44170e Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Wed, 24 Jan 2024 23:35:04 +0100
Subject: [PATCH] WIP

---
 src/test/java/de/juplo/kafka/ApplicationTests.java | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/src/test/java/de/juplo/kafka/ApplicationTests.java b/src/test/java/de/juplo/kafka/ApplicationTests.java
index 28f81d6..581658e 100644
--- a/src/test/java/de/juplo/kafka/ApplicationTests.java
+++ b/src/test/java/de/juplo/kafka/ApplicationTests.java
@@ -39,7 +39,8 @@ public class ApplicationTests
     SimpleProducer instanceA = new SimpleProducer(
       bootstrapServers,
       TOPIC,
-      "FOO");
+      "FOO",
+      "A");
 
     instanceA.begin();
     CompletableFuture<Long> resultA1 = instanceA.send("a","message #1");
@@ -51,7 +52,8 @@ public class ApplicationTests
     SimpleProducer instanceB = new SimpleProducer(
       bootstrapServers,
       TOPIC,
-      "FOO");
+      "FOO",
+      "B");
 
     instanceB.begin();
     CompletableFuture<Long> resultB1 = instanceB.send("b","message #1");
-- 
2.20.1