KAFKADATA

diff --git a/src/test/java/de/juplo/kafka/chat/backend/KafkaConfigurationIT.java b/src/test/java/de/juplo/kafka/chat/backend/KafkaConfigurationIT.java
index e633cb9..c2fd109 100644 (file)
--- a/src/test/java/de/juplo/kafka/chat/backend/KafkaConfigurationIT.java
+++ b/src/test/java/de/juplo/kafka/chat/backend/KafkaConfigurationIT.java
@@ -14,7 +14,13 @@ import static de.juplo.kafka.chat.backend.KafkaConfigurationIT.TOPIC;
         "chat.backend.kafka.bootstrap-servers=${spring.embedded.kafka.brokers}",
         "chat.backend.kafka.topic=" + TOPIC,
         "chat.backend.kafka.num-partitions=3" })
-@EmbeddedKafka(topics = TOPIC, partitions = 3)
+@EmbeddedKafka(
+    brokerProperties = {
+        "cluster.id=uOUpZcdSSgGXsJbN2RlkjA",
+        "data.dir=target/test-classes/data/kafka"
+    },
+    topics = TOPIC,
+    partitions = 3)
 class KafkaConfigurationIT extends AbstractConfigurationIT
 {
   final static String TOPIC = "TEST";

diff --git a/src/test/resources/data/kafka/cleaner-offset-checkpoint b/src/test/resources/data/kafka/cleaner-offset-checkpoint
new file mode 100644 (file)
index 0000000..e69de29

diff --git a/src/test/resources/data/kafka/log-start-offset-checkpoint b/src/test/resources/data/kafka/log-start-offset-checkpoint
new file mode 100644 (file)
index 0000000..aa47d0d
--- /dev/null
+++ b/src/test/resources/data/kafka/log-start-offset-checkpoint
@@ -0,0 +1,2 @@
+0
+0

diff --git a/src/test/resources/data/kafka/meta.properties b/src/test/resources/data/kafka/meta.properties
new file mode 100644 (file)
index 0000000..f18751e
--- /dev/null
+++ b/src/test/resources/data/kafka/meta.properties
@@ -0,0 +1,5 @@
+#
+#Thu Apr 20 13:23:51 CEST 2023
+broker.id=0
+version=0
+cluster.id=uOUpZcdSSgGXsJbN2RlkjA

diff --git a/src/test/resources/data/kafka/recovery-point-offset-checkpoint b/src/test/resources/data/kafka/recovery-point-offset-checkpoint
new file mode 100644 (file)
index 0000000..92031d9
--- /dev/null
+++ b/src/test/resources/data/kafka/recovery-point-offset-checkpoint
@@ -0,0 +1,5 @@
+0
+8
+TEST 0 0
+TEST 1 0
+TEST 2 0

diff --git a/src/test/resources/data/kafka/replication-offset-checkpoint b/src/test/resources/data/kafka/replication-offset-checkpoint
new file mode 100644 (file)
index 0000000..d3a114c
--- /dev/null
+++ b/src/test/resources/data/kafka/replication-offset-checkpoint
@@ -0,0 +1,5 @@
+0
+3
+TEST 0 0
+TEST 1 0
+TEST 2 0