Skip to content

Commit

Permalink
Merge pull request #50 from data-catering/kafka-init
Browse files Browse the repository at this point in the history
Fix kafka init by using port 29092 when creating topics
  • Loading branch information
pflooky authored Jul 12, 2024
2 parents c86ece9 + a0dae71 commit 39b9206
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion data/kafka/init.sh
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@ fi

echo "Creating kafka topics"
for t in $(echo "$KAFKA_TOPICS" | sed s/,/\\n/g); do
kafka-topics --create --if-not-exists --topic "${t}" --bootstrap-server ${host}:9092 --replication-factor 1 --partitions 1
kafka-topics --create --if-not-exists --topic "${t}" --bootstrap-server ${host}:29092 --replication-factor 1 --partitions 1
done

echo "Successfully created the following topics:"
Expand Down

0 comments on commit 39b9206

Please sign in to comment.