Use general kafka topic creation in self-hosted (getsentry#3121)

* use general kafka topic creation
Algo-Trading-Tools · Jun 20, 2024 · fdf7eab · fdf7eab
1 parent b1dcac8
commit fdf7eab
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 35 deletions.
diff --git a/install.sh b/install.sh
@@ -34,7 +34,6 @@ source install/update-docker-images.sh
 source install/build-docker-images.sh
 source install/install-wal2json.sh
 source install/bootstrap-snuba.sh
-source install/create-kafka-topics.sh
 source install/upgrade-postgres.sh
 source install/set-up-and-migrate-database.sh
 source install/geoip.sh

diff --git a/install/create-kafka-topics.sh b/install/create-kafka-topics.sh
diff --git a/install/set-up-and-migrate-database.sh b/install/set-up-and-migrate-database.sh
@@ -19,15 +19,15 @@ with connection.cursor() as cursor:
 "
 
 if [[ -n "${CI:-}" || "${SKIP_USER_CREATION:-0}" == 1 ]]; then
-  $dcr web upgrade --noinput
+  $dcr web upgrade --noinput --create-kafka-topics
   echo ""
   echo "Did not prompt for user creation. Run the following command to create one"
   echo "yourself (recommended):"
   echo ""
   echo "  $dc_base run --rm web createuser"
   echo ""
 else
-  $dcr web upgrade
+  $dcr web upgrade --create-kafka-topics
 fi
 
 echo "${_endgroup}"