From a659b69953c4d2ff12da0c77220ae8d91a019af8 Mon Sep 17 00:00:00 2001
From: Anton Ovchinnikov <anton@tonyo.info>
Date: Fri, 25 Sep 2020 14:02:00 +0200
Subject: [PATCH] fix(install): Check that all ingest topics exist

---
 install.sh | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/install.sh b/install.sh
index 33f0eadaa61..88e069a5a45 100755
--- a/install.sh
+++ b/install.sh
@@ -250,7 +250,7 @@ echo ""
 EXISTING_KAFKA_TOPICS=$($dcr kafka kafka-topics --list --bootstrap-server kafka:9092 2>/dev/null)
 NEEDED_KAFKA_TOPICS="ingest-attachments ingest-transactions ingest-events"
 for topic in $NEEDED_KAFKA_TOPICS; do
-  if ! echo "$EXISTING_KAFKA_TOPICS" | grep -wq ingest-attachments; then
+  if ! echo "$EXISTING_KAFKA_TOPICS" | grep -wq $topic; then
     echo "Creating additional Kafka topics..."
     $dcr kafka kafka-topics --create --topic $topic --bootstrap-server kafka:9092
     echo ""