lsm/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2025-10-08 03:34:24 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

wait for schema registry

Browse Source
This commit is contained in:
chrislu
2025-10-06 20:46:14 -07:00
parent b03d8a525f
commit cf77b44238
1 changed files with 28 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
test/kafka/kafka-client-loadtest/scripts/wait-for-services.sh
View File

@@ -99,8 +99,23 @@ check_schema_registry() {
return 0
fi
# FIXED: Wait for Docker healthcheck to report "healthy", not just "Up"
# Schema Registry has a 30s start_period, so we need to wait for the actual healthcheck
local health_status
health_status=$(docker inspect loadtest-schema-registry --format='{{.State.Health.Status}}' 2>/dev/null || echo "none")
# If container has no healthcheck or healthcheck is not yet healthy, check HTTP directly
if [[ "$health_status" == "healthy" ]]; then
# Container reports healthy, do a final verification
if check_http_service "$SCHEMA_REGISTRY_URL/subjects" "Schema Registry"; then
return 0
fi
elif [[ "$health_status" == "starting" ]]; then
# Still in startup period, wait longer
return 1
elif [[ "$health_status" == "none" ]]; then
# No healthcheck defined (shouldn't happen), fall back to HTTP check
if check_http_service "$SCHEMA_REGISTRY_URL/subjects" "Schema Registry"; then
# Additional check: ensure schema registry is connected to Kafka
local subjects
subjects=$(curl -s "$SCHEMA_REGISTRY_URL/subjects" 2>/dev/null || echo "[]")
@@ -114,6 +129,7 @@ check_schema_registry() {
return 1
fi
fi
fi
return 1
}