From: Kai Moritz <kai@juplo.de>
Date: Tue, 28 Jan 2025 20:47:45 +0000 (+0100)
Subject: WIP
X-Git-Url: https://juplo.de/gitweb/?a=commitdiff_plain;h=784b59fbbb4735afde50f15faa9e61c326319581;p=demos%2Fkafka%2Ftraining

WIP
---

diff --git a/src/test/java/de/juplo/kafka/ApplicationTests.java b/src/test/java/de/juplo/kafka/ApplicationTests.java
index 76b9efe8..3b62dc48 100644
--- a/src/test/java/de/juplo/kafka/ApplicationTests.java
+++ b/src/test/java/de/juplo/kafka/ApplicationTests.java
@@ -1,5 +1,6 @@
 package de.juplo.kafka;
 
+import de.juplo.test.MessageAdd;
 import org.apache.kafka.clients.admin.AdminClient;
 import org.apache.kafka.clients.admin.AdminClientConfig;
 import org.apache.kafka.clients.admin.RecordsToDelete;
@@ -62,6 +63,13 @@ public class ApplicationTests
         .andExpect(jsonPath("status").value("UP")));
   }
 
+  @Test
+  public void testMessageAdd()
+  {
+    String key = "foo";
+    Integer value = 6;
+    send(key, MessageAdd.builder().key(key).next(value).build());
+  }
 
 
   final long[] currentOffsets = new long[PARTITIONS];
diff --git a/src/test/java/de/juplo/test/MessageAdd.java b/src/test/java/de/juplo/test/MessageAdd.java
new file mode 100644
index 00000000..2bf33dd8
--- /dev/null
+++ b/src/test/java/de/juplo/test/MessageAdd.java
@@ -0,0 +1,13 @@
+package de.juplo.test;
+
+import lombok.Builder;
+import lombok.Data;
+
+
+@Data
+@Builder
+public class MessageAdd
+{
+  String key;
+  Integer next;
+}
diff --git a/src/test/java/de/juplo/test/MessageCalc.java b/src/test/java/de/juplo/test/MessageCalc.java
new file mode 100644
index 00000000..54379614
--- /dev/null
+++ b/src/test/java/de/juplo/test/MessageCalc.java
@@ -0,0 +1,10 @@
+package de.juplo.test;
+
+import lombok.Data;
+
+
+@Data
+public class MessageCalc
+{
+  String key;
+}
diff --git a/src/test/java/de/juplo/test/MessageInvalid.java b/src/test/java/de/juplo/test/MessageInvalid.java
new file mode 100644
index 00000000..3fa1d18b
--- /dev/null
+++ b/src/test/java/de/juplo/test/MessageInvalid.java
@@ -0,0 +1,11 @@
+package de.juplo.test;
+
+import lombok.Data;
+
+
+@Data
+public class MessageInvalid
+{
+  String key;
+  String text;
+}