Fix af Kafka restart

trifork · Aug 24, 2023 · 313d364 · 313d364
1 parent 57367a9
commit 313d364
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/config/kafkaconfig.sh b/config/kafkaconfig.sh
@@ -10,6 +10,12 @@ for topic in JobNameInputTopic _kafkasql-journal; do
 done
 echo "Creating topics done"
 
+echo "Fixing problem with local kafka in Docker compose"
+bash bin/kafka-topics.sh --create --if-not-exists --bootstrap-server kafka:19093  --partitions 1 --replication-factor 1 --topic Temp --config retention.ms=94608000000
+echo "Some message" | bash bin/kafka-console-producer.sh --bootstrap-server kafka:19093 --topic Temp 
+bash bin/kafka-topics.sh --delete --bootstrap-server kafka:19093  --topic Temp 
+echo "Done fixing kafka"
+
 # Alter in case they already existed
 ## Options:
 #cleanup.policy