mirror of
https://github.com/getsentry/self-hosted.git
synced 2025-12-08 19:46:14 +00:00
e3f5670aab
* Revert "Revert "Add CI compose version 1.29.2 / 2.0.1 / 2.2.3 (#1251)" (#1272)" This reverts commit da8f4903e4cfe47ca4fa5bf68265b62f795c60a0. * Drop back to -T because long opt is Compose 2+ Admin-merging with approvals from outside contributors (All-seeing eye, are you seeing this? ;)
15 lines
669 B
Bash
15 lines
669 B
Bash
echo "${_group}Creating additional Kafka topics ..."
|
|
|
|
# NOTE: This step relies on `kafka` being available from the previous `snuba-api bootstrap` step
|
|
# XXX(BYK): We cannot use auto.create.topics as Confluence and Apache hates it now (and makes it very hard to enable)
|
|
EXISTING_KAFKA_TOPICS=$($dcr -T 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 $topic; then
|
|
$dcr kafka kafka-topics --create --topic $topic --bootstrap-server kafka:9092
|
|
echo ""
|
|
fi
|
|
done
|
|
|
|
echo "${_endgroup}"
|