Fix advertised broker ip

port 9092 is not exposed to the host, so we can not connect to it via host ip, but need to use the broker container ip
testcontainers · Dec 8, 2023 · 96f033c · 96f033c
1 parent e983907
commit 96f033c
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/modules/kafka/kafka.go b/modules/kafka/kafka.go
@@ -72,12 +72,17 @@ func RunContainer(ctx context.Context, opts ...testcontainers.ContainerCustomize
 							return err
 						}
 
+						ip, err := c.ContainerIP(ctx)
+						if err != nil {
+							return err
+						}
+
 						port, err := c.MappedPort(ctx, publicPort)
 						if err != nil {
 							return err
 						}
 
-						scriptContent := fmt.Sprintf(starterScriptContent, host, port.Int(), host)
+						scriptContent := fmt.Sprintf(starterScriptContent, host, port.Int(), ip)
 
 						return c.CopyToContainer(ctx, []byte(scriptContent), starterScript, 0o755)
 					},