create-kafka-topics.sh
No OneTemporary
Actions

Size

669 B

Subscribers

None

create-kafka-topics.sh
View Options

	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}"

File Metadata

Mime Type: text/plain
Expires: Sat, Jun 21, 8:57 PM (3 w, 6 d ago)
Storage Engine: blob
Storage Format: Raw Data
Storage Handle: 3249895

Event Timeline