From 853d422015c2450472c44d967f16254b3fd45fb1 Mon Sep 17 00:00:00 2001
From: Julien Jean Paul Sirocchi <julien.sirocchi@gmail.com>
Date: Thu, 1 Feb 2024 13:10:32 -0800
Subject: [PATCH] fixed examples and included sink compaction as env variable
 for all

---
 db/local/runDatabaseSimple.sh                       | 1 +
 example/src/main/scala/tamer/s3/S3Generalized.scala | 4 ++--
 rest/local/runRestBasicAuth.sh                      | 1 +
 rest/local/runRestCustomAuth.sh                     | 1 +
 rest/local/runRestDynamicData.sh                    | 1 +
 rest/local/runRestSimple.sh                         | 1 +
 s3/local/runS3Generalized.sh                        | 1 +
 s3/local/runS3Simple.sh                             | 1 +
 8 files changed, 9 insertions(+), 2 deletions(-)

diff --git a/db/local/runDatabaseSimple.sh b/db/local/runDatabaseSimple.sh
index 8a050ded..07dfec47 100755
--- a/db/local/runDatabaseSimple.sh
+++ b/db/local/runDatabaseSimple.sh
@@ -20,6 +20,7 @@ export KAFKA_STATE_TOPIC=state
 export KAFKA_STATE_AUTO_CREATE=on
 export KAFKA_STATE_PARTITIONS=1
 export KAFKA_STATE_REPLICAS=1
+export KAFKA_STATE_COMPACTION=on
 export KAFKA_GROUP_ID=groupid
 export KAFKA_CLIENT_ID=clientid
 export KAFKA_TRANSACTIONAL_ID=transactionid
diff --git a/example/src/main/scala/tamer/s3/S3Generalized.scala b/example/src/main/scala/tamer/s3/S3Generalized.scala
index 2f0b972e..6918153d 100644
--- a/example/src/main/scala/tamer/s3/S3Generalized.scala
+++ b/example/src/main/scala/tamer/s3/S3Generalized.scala
@@ -38,8 +38,8 @@ object S3Generalized extends ZIOAppDefault {
       Some(RegistryConfig("http://localhost:8081")),
       10.seconds,
       50,
-      TopicConfig("sink", Some(TopicOptions(1, 1))),
-      TopicConfig("state", Some(TopicOptions(1, 1))),
+      TopicConfig("sink", Some(TopicOptions(1, 1, false))),
+      TopicConfig("state", Some(TopicOptions(1, 1, true))),
       "groupid",
       "clientid",
       "s3-generalized-id"
diff --git a/rest/local/runRestBasicAuth.sh b/rest/local/runRestBasicAuth.sh
index efd59d9a..cf0cb915 100755
--- a/rest/local/runRestBasicAuth.sh
+++ b/rest/local/runRestBasicAuth.sh
@@ -15,6 +15,7 @@ export KAFKA_STATE_TOPIC=state
 export KAFKA_STATE_AUTO_CREATE=on
 export KAFKA_STATE_PARTITIONS=1
 export KAFKA_STATE_REPLICAS=1
+export KAFKA_STATE_COMPACTION=on
 export KAFKA_GROUP_ID=groupid
 export KAFKA_CLIENT_ID=clientid
 export KAFKA_TRANSACTIONAL_ID=transactionid
diff --git a/rest/local/runRestCustomAuth.sh b/rest/local/runRestCustomAuth.sh
index f842bd85..b92366af 100755
--- a/rest/local/runRestCustomAuth.sh
+++ b/rest/local/runRestCustomAuth.sh
@@ -15,6 +15,7 @@ export KAFKA_STATE_TOPIC=state
 export KAFKA_STATE_AUTO_CREATE=on
 export KAFKA_STATE_PARTITIONS=1
 export KAFKA_STATE_REPLICAS=1
+export KAFKA_STATE_COMPACTION=on
 export KAFKA_GROUP_ID=groupid
 export KAFKA_CLIENT_ID=clientid
 export KAFKA_TRANSACTIONAL_ID=transactionid
diff --git a/rest/local/runRestDynamicData.sh b/rest/local/runRestDynamicData.sh
index ba36fcd9..19e0ac11 100755
--- a/rest/local/runRestDynamicData.sh
+++ b/rest/local/runRestDynamicData.sh
@@ -15,6 +15,7 @@ export KAFKA_STATE_TOPIC=state
 export KAFKA_STATE_AUTO_CREATE=on
 export KAFKA_STATE_PARTITIONS=1
 export KAFKA_STATE_REPLICAS=1
+export KAFKA_STATE_COMPACTION=on
 export KAFKA_GROUP_ID=groupid
 export KAFKA_CLIENT_ID=clientid
 export KAFKA_TRANSACTIONAL_ID=transactionid
diff --git a/rest/local/runRestSimple.sh b/rest/local/runRestSimple.sh
index db37726b..7b3d4178 100755
--- a/rest/local/runRestSimple.sh
+++ b/rest/local/runRestSimple.sh
@@ -15,6 +15,7 @@ export KAFKA_STATE_TOPIC=state
 export KAFKA_STATE_AUTO_CREATE=on
 export KAFKA_STATE_PARTITIONS=1
 export KAFKA_STATE_REPLICAS=1
+export KAFKA_STATE_COMPACTION=on
 export KAFKA_GROUP_ID=groupid
 export KAFKA_CLIENT_ID=clientid
 export KAFKA_TRANSACTIONAL_ID=transactionid
diff --git a/s3/local/runS3Generalized.sh b/s3/local/runS3Generalized.sh
index bbcbfc1d..5c59be55 100755
--- a/s3/local/runS3Generalized.sh
+++ b/s3/local/runS3Generalized.sh
@@ -17,6 +17,7 @@ export KAFKA_STATE_TOPIC=state
 export KAFKA_STATE_AUTO_CREATE=on
 export KAFKA_STATE_PARTITIONS=1
 export KAFKA_STATE_REPLICAS=1
+export KAFKA_STATE_COMPACTION=on
 export KAFKA_GROUP_ID=groupid
 export KAFKA_CLIENT_ID=clientid
 export KAFKA_TRANSACTIONAL_ID=transactionid
diff --git a/s3/local/runS3Simple.sh b/s3/local/runS3Simple.sh
index bc616e04..abf7a14b 100755
--- a/s3/local/runS3Simple.sh
+++ b/s3/local/runS3Simple.sh
@@ -17,6 +17,7 @@ export KAFKA_STATE_TOPIC=state
 export KAFKA_STATE_AUTO_CREATE=on
 export KAFKA_STATE_PARTITIONS=1
 export KAFKA_STATE_REPLICAS=1
+export KAFKA_STATE_COMPACTION=on
 export KAFKA_GROUP_ID=groupid
 export KAFKA_CLIENT_ID=clientid
 export KAFKA_TRANSACTIONAL_ID=transactionid