1
0
Fork 0
mirror of https://github.com/chrislusf/seaweedfs synced 2025-09-19 01:30:23 +02:00
seaweedfs/test/kafka/cmd/setup
chrislu 2809081bd4 fix: correct Kafka Gateway health check to use TCP dial instead of HTTP
- Changed waitForService to separate waitForHTTPService and waitForTCPService functions
- Kafka Gateway health check now uses TCP dial against port 9093 instead of HTTP GET
- HTTP GET against Kafka protocol port was causing setup failures with connection refused
- Added proper timeout handling for TCP dial (2 seconds per attempt)

This fixes the critical issue where test setup would fail when trying to verify
Kafka Gateway availability using the wrong protocol.
2025-09-16 00:22:46 -07:00
..
main.go fix: correct Kafka Gateway health check to use TCP dial instead of HTTP 2025-09-16 00:22:46 -07:00