fix(redpanda): add wait for listening port condition (#1828)

testcontainers · Oct 27, 2023 · aad7074 · aad7074
1 parent 395fe10
commit aad7074
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/modules/redpanda/redpanda.go b/modules/redpanda/redpanda.go
@@ -176,9 +176,11 @@ func RunContainer(ctx context.Context, opts ...testcontainers.ContainerCustomize
 	}
 
 	// 6. Wait until Redpanda is ready to serve requests
-	err = wait.ForLog("Successfully started Redpanda!").
-		WithPollInterval(100*time.Millisecond).
+	err = wait.ForAll(
+		wait.ForListeningPort(defaultKafkaAPIPort),
+		wait.ForLog("Successfully started Redpanda!").WithPollInterval(100*time.Millisecond)).
 		WaitUntilReady(ctx, container)
+
 	if err != nil {
 		return nil, fmt.Errorf("failed to wait for Redpanda readiness: %w", err)
 	}