We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3408e3d commit 0a4b2adCopy full SHA for 0a4b2ad
install.sh
@@ -250,7 +250,7 @@ echo ""
250
EXISTING_KAFKA_TOPICS=$($dcr kafka kafka-topics --list --bootstrap-server kafka:9092 2>/dev/null)
251
NEEDED_KAFKA_TOPICS="ingest-attachments ingest-transactions ingest-events"
252
for topic in $NEEDED_KAFKA_TOPICS; do
253
- if ! echo "$EXISTING_KAFKA_TOPICS" | grep -wq ingest-attachments; then
+ if ! echo "$EXISTING_KAFKA_TOPICS" | grep -wq $topic; then
254
echo "Creating additional Kafka topics..."
255
$dcr kafka kafka-topics --create --topic $topic --bootstrap-server kafka:9092
256
echo ""
0 commit comments