fixed examples and included sink compaction as env variable for all

laserdisc-io · Feb 1, 2024 · 853d422 · 853d422
1 parent 20e631f
commit 853d422
Show file tree

Hide file tree

Showing 8 changed files with 9 additions and 2 deletions.
diff --git 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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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