blob: 08561cef52532a2ff83eb20c4000b5ca27498719 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
|
#!/bin/sh
# Kafka Gateway Startup Script for Integration Testing
set -e
echo "Starting Kafka Gateway..."
SEAWEEDFS_MASTERS=${SEAWEEDFS_MASTERS:-seaweedfs-master:9333}
SEAWEEDFS_FILER=${SEAWEEDFS_FILER:-seaweedfs-filer:8888}
SEAWEEDFS_MQ_BROKER=${SEAWEEDFS_MQ_BROKER:-seaweedfs-mq-broker:17777}
SEAWEEDFS_FILER_GROUP=${SEAWEEDFS_FILER_GROUP:-}
# Wait for dependencies
echo "Waiting for SeaweedFS master(s)..."
OLD_IFS="$IFS"
IFS=','
for MASTER in $SEAWEEDFS_MASTERS; do
MASTER_HOST=${MASTER%:*}
MASTER_PORT=${MASTER#*:}
while ! nc -z "$MASTER_HOST" "$MASTER_PORT"; do
sleep 1
done
echo "SeaweedFS master $MASTER is ready"
done
IFS="$OLD_IFS"
echo "Waiting for SeaweedFS Filer..."
while ! nc -z "${SEAWEEDFS_FILER%:*}" "${SEAWEEDFS_FILER#*:}"; do
sleep 1
done
echo "SeaweedFS Filer is ready"
echo "Waiting for SeaweedFS MQ Broker..."
while ! nc -z "${SEAWEEDFS_MQ_BROKER%:*}" "${SEAWEEDFS_MQ_BROKER#*:}"; do
sleep 1
done
echo "SeaweedFS MQ Broker is ready"
echo "Waiting for Schema Registry..."
while ! curl -f "${SCHEMA_REGISTRY_URL}/subjects" > /dev/null 2>&1; do
sleep 1
done
echo "Schema Registry is ready"
# Start Kafka Gateway
echo "Starting Kafka Gateway on port ${KAFKA_PORT:-9093}..."
exec /usr/bin/weed mq.kafka.gateway \
-master=${SEAWEEDFS_MASTERS} \
-filerGroup=${SEAWEEDFS_FILER_GROUP} \
-port=${KAFKA_PORT:-9093} \
-port.pprof=${PPROF_PORT:-10093} \
-schema-registry-url=${SCHEMA_REGISTRY_URL} \
-ip=0.0.0.0
|
