96 lines
2.8 KiB
YAML
96 lines
2.8 KiB
YAML
name: telecom-cdr-pipeline
|
|
|
|
services:
|
|
redpanda:
|
|
image: docker.redpanda.com/redpandadata/redpanda:${REDPANDA_VERSION:-v26.2.3}
|
|
|
|
container_name: telecom-redpanda
|
|
|
|
command:
|
|
- redpanda
|
|
- start
|
|
|
|
# Kafka listeners:
|
|
# 9092 -> other Docker containers
|
|
# 19092 -> applications running on our host machine
|
|
- --kafka-addr=internal://0.0.0.0:9092,external://0.0.0.0:19092
|
|
|
|
# These are the addresses Redpanda tells Kafka clients to use.
|
|
- --advertise-kafka-addr=internal://redpanda:9092,external://localhost:19092
|
|
|
|
# Internal Redpanda node communication.
|
|
- --rpc-addr=redpanda:33145
|
|
- --advertise-rpc-addr=redpanda:33145
|
|
|
|
# Suitable settings for local Docker development.
|
|
- --mode=dev-container
|
|
- --smp=1
|
|
- --default-log-level=info
|
|
|
|
ports:
|
|
- "19092:19092"
|
|
- "9644:9644" # Redpanda's Admin API
|
|
|
|
volumes:
|
|
- redpanda-data:/var/lib/redpanda/data
|
|
|
|
healthcheck:
|
|
test:
|
|
[
|
|
"CMD",
|
|
"rpk",
|
|
"cluster",
|
|
"health",
|
|
"--exit-when-healthy"
|
|
]
|
|
interval: 5s
|
|
timeout: 10s
|
|
retries: 10
|
|
start_period: 10s
|
|
|
|
redpanda-init:
|
|
image: docker.redpanda.com/redpandadata/redpanda:${REDPANDA_VERSION:-v26.2.3}
|
|
|
|
depends_on:
|
|
redpanda:
|
|
condition: service_healthy
|
|
|
|
environment:
|
|
KAFKA_BOOTSTRAP_SERVERS: ${KAFKA_BOOTSTRAP_SERVERS}
|
|
|
|
KAFKA_RAW_TOPIC: ${KAFKA_RAW_TOPIC}
|
|
KAFKA_RAW_TOPIC_PARTITIONS: ${KAFKA_RAW_TOPIC_PARTITIONS}
|
|
KAFKA_RAW_TOPIC_REPLICATION_FACTOR: ${KAFKA_RAW_TOPIC_REPLICATION_FACTOR}
|
|
KAFKA_RAW_TOPIC_RETENTION_MS: ${KAFKA_RAW_TOPIC_RETENTION_MS}
|
|
KAFKA_RAW_TOPIC_COMPRESSION: ${KAFKA_RAW_TOPIC_COMPRESSION}
|
|
|
|
KAFKA_DLQ_TOPIC: ${KAFKA_DLQ_TOPIC}
|
|
KAFKA_DLQ_TOPIC_PARTITIONS: ${KAFKA_DLQ_TOPIC_PARTITIONS}
|
|
KAFKA_DLQ_TOPIC_REPLICATION_FACTOR: ${KAFKA_DLQ_TOPIC_REPLICATION_FACTOR}
|
|
KAFKA_DLQ_TOPIC_RETENTION_MS: ${KAFKA_DLQ_TOPIC_RETENTION_MS}
|
|
|
|
entrypoint: ["/bin/bash", "-c"]
|
|
|
|
command:
|
|
- |
|
|
echo "Creating Kafka topics..."
|
|
|
|
rpk topic create "$$KAFKA_RAW_TOPIC" \
|
|
--if-not-exists \
|
|
--brokers "$$KAFKA_BOOTSTRAP_SERVERS" \
|
|
-p "$$KAFKA_RAW_TOPIC_PARTITIONS" \
|
|
-r "$$KAFKA_RAW_TOPIC_REPLICATION_FACTOR" \
|
|
-c retention.ms="$$KAFKA_RAW_TOPIC_RETENTION_MS" \
|
|
-c compression.type="$$KAFKA_RAW_TOPIC_COMPRESSION"
|
|
|
|
rpk topic create "$$KAFKA_DLQ_TOPIC" \
|
|
--if-not-exists \
|
|
--brokers "$$KAFKA_BOOTSTRAP_SERVERS" \
|
|
-p "$$KAFKA_DLQ_TOPIC_PARTITIONS" \
|
|
-r "$$KAFKA_DLQ_TOPIC_REPLICATION_FACTOR" \
|
|
-c retention.ms="$$KAFKA_DLQ_TOPIC_RETENTION_MS"
|
|
|
|
echo "Kafka topics initialized successfully."
|
|
|
|
volumes:
|
|
redpanda-data: |