From d5c516f51ed06acd991880e07ea5a2f3b5b160b9 Mon Sep 17 00:00:00 2001 From: Dan Fuller Date: Mon, 3 Jun 2024 14:14:18 -0700 Subject: [PATCH] add if statement --- install/create-kafka-topics.sh | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/install/create-kafka-topics.sh b/install/create-kafka-topics.sh index 6d6a7c078b..ff2ba8e660 100644 --- a/install/create-kafka-topics.sh +++ b/install/create-kafka-topics.sh @@ -24,6 +24,9 @@ done # This topic must have only a single partition for the consumer to work correctly # https://github.com/getsentry/ops/blob/7dbc26f39c584ec924c8fef2ad5c532d6a158be3/k8s/clusters/us/_topicctl.yaml#L288-L295 -$dc exec kafka kafka-topics --create --topic monitors-clock-tick --bootstrap-server kafka:9092 --partitions 1 + +if ! echo "$EXISTING_KAFKA_TOPICS" | grep -qE "(^| )monitors-clock-tick( |$)"; then + $dc exec kafka kafka-topics --create --topic monitors-clock-tick --bootstrap-server kafka:9092 --partitions 1 +fi echo "${_endgroup}"