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

* use general kafka topic creation

Author: hubertdeng123

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

install/create-kafka-topics.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}"