From e607a7742750354cc25853e4bc2706a5b9be18e7 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Tue, 28 Jan 2025 21:51:03 +0100
Subject: [PATCH] WIP

---
 .../java/de/juplo/kafka/ApplicationTests.java | 22 +++++++++++++++++++
 src/test/java/de/juplo/test/MessageCalc.java  |  2 ++
 .../java/de/juplo/test/MessageInvalid.java    |  2 ++
 3 files changed, 26 insertions(+)

diff --git a/src/test/java/de/juplo/kafka/ApplicationTests.java b/src/test/java/de/juplo/kafka/ApplicationTests.java
index 3b62dc48..54185e19 100644
--- a/src/test/java/de/juplo/kafka/ApplicationTests.java
+++ b/src/test/java/de/juplo/kafka/ApplicationTests.java
@@ -1,6 +1,8 @@
 package de.juplo.kafka;
 
 import de.juplo.test.MessageAdd;
+import de.juplo.test.MessageCalc;
+import de.juplo.test.MessageInvalid;
 import org.apache.kafka.clients.admin.AdminClient;
 import org.apache.kafka.clients.admin.AdminClientConfig;
 import org.apache.kafka.clients.admin.RecordsToDelete;
@@ -71,6 +73,26 @@ public class ApplicationTests
     send(key, MessageAdd.builder().key(key).next(value).build());
   }
 
+  @Test
+  public void testMessageCalc()
+  {
+    String key = "foo";
+    send(key, MessageCalc.builder().key(key).build());
+  }
+
+  @Test
+  public void testMessageInvalid()
+  {
+    String key = "foo";
+    send(key, MessageInvalid.builder().key(key).build());
+    await("Application is healthy")
+      .atMost(Duration.ofSeconds(5))
+      .untilAsserted(() -> mockMvc
+        .perform(get("/actuator/health"))
+        .andExpect(status().isOk())
+        .andExpect(jsonPath("status").value("UP")));
+  }
+
 
   final long[] currentOffsets = new long[PARTITIONS];
   @Autowired
diff --git a/src/test/java/de/juplo/test/MessageCalc.java b/src/test/java/de/juplo/test/MessageCalc.java
index 54379614..1237b822 100644
--- a/src/test/java/de/juplo/test/MessageCalc.java
+++ b/src/test/java/de/juplo/test/MessageCalc.java
@@ -1,9 +1,11 @@
 package de.juplo.test;
 
+import lombok.Builder;
 import lombok.Data;
 
 
 @Data
+@Builder
 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
index 3fa1d18b..24fdafde 100644
--- a/src/test/java/de/juplo/test/MessageInvalid.java
+++ b/src/test/java/de/juplo/test/MessageInvalid.java
@@ -1,9 +1,11 @@
 package de.juplo.test;
 
+import lombok.Builder;
 import lombok.Data;
 
 
 @Data
+@Builder
 public class MessageInvalid
 {
   String key;
-- 
2.20.1