28 lines
1.6 KiB
YAML
28 lines
1.6 KiB
YAML
version: '3.7'
|
|
services:
|
|
init-kafka:
|
|
image: confluentinc/cp-kafka:${KAFKA_VERSION}
|
|
entrypoint: [ '/bin/sh', '-c' ]
|
|
command: |
|
|
"
|
|
# block until kafka is reachable
|
|
kafka-topics --bootstrap-server kafka-broker-1:9092 --list
|
|
|
|
echo -e 'Deleting kafka topics'
|
|
kafka-topics --bootstrap-server kafka-broker-1:9092 --topic payment-request-value --delete --if-exists
|
|
kafka-topics --bootstrap-server kafka-broker-1:9092 --topic payment-response-value --delete --if-exists
|
|
kafka-topics --bootstrap-server kafka-broker-1:9092 --topic restaurant-approval-request-value --delete --if-exists
|
|
kafka-topics --bootstrap-server kafka-broker-1:9092 --topic restaurant-approval-response-value --delete --if-exists
|
|
|
|
echo -e 'Creating kafka topics'
|
|
kafka-topics --bootstrap-server kafka-broker-1:9092 --create --if-not-exists --topic payment-request-value --replication-factor 3 --partitions 3
|
|
kafka-topics --bootstrap-server kafka-broker-1:9092 --create --if-not-exists --topic payment-response-value --replication-factor 3 --partitions 3
|
|
kafka-topics --bootstrap-server kafka-broker-1:9092 --create --if-not-exists --topic restaurant-approval-request-value --replication-factor 3 --partitions 3
|
|
kafka-topics --bootstrap-server kafka-broker-1:9092 --create --if-not-exists --topic restaurant-approval-response-value --replication-factor 3 --partitions 3
|
|
|
|
|
|
echo -e 'Successfully created the following topics:'
|
|
kafka-topics --bootstrap-server kafka-broker-1:9092 --list
|
|
"
|
|
networks:
|
|
- ${GLOBAL_NETWORK:-kafka} |