From: Kai Moritz <kai@juplo.de>
Date: Thu, 20 Apr 2023 11:32:34 +0000 (+0200)
Subject: KAFKADATA
X-Git-Tag: kafkadata~2
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=6b578111da2c5e3918b6dde2ee4e518404637060;p=demos%2Fkafka%2Fchat

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 e633cb92..c2fd109e 100644
--- 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
index 00000000..e69de29b
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
index 00000000..aa47d0d4
--- /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
index 00000000..f18751e9
--- /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
index 00000000..92031d9d
--- /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
index 00000000..d3a114c7
--- /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