1 files changed, 54 insertions, 0 deletions
diff --git a/test/kafka/scripts/kafka-gateway-start.sh b/test/kafka/scripts/kafka-gateway-start.sh
new file mode 100755
index 000000000..08561cef5
--- /dev/null
+++ b/test/kafka/scripts/kafka-gateway-start.sh
@@ -0,0 +1,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