fix(modules.kafka): Use broker container IP instead of host IP for advertised broker listener

container.go

@@ -62,6 +62,7 @@ type Container interface {
 	CopyFileToContainer(ctx context.Context, hostFilePath string, containerFilePath string, fileMode int64) error
 	CopyFileFromContainer(ctx context.Context, filePath string) (io.ReadCloser, error)
 	GetLogProductionErrorChannel() <-chan error
+	Hostname(ctx context.Context) (string, error)
 }
 
 // ImageBuildInfo defines what is needed to build an image

docker.go

@@ -392,6 +392,15 @@ func (c *DockerContainer) Name(ctx context.Context) (string, error) {
 	return inspect.Name, nil
 }
 
+// Hostname gets the name of the container.
+func (c *DockerContainer) Hostname(ctx context.Context) (string, error) {
+	inspect, err := c.inspectContainer(ctx)
+	if err != nil {
+		return "", err
+	}
+	return inspect.Config.Hostname, nil
+}
+
 // State returns container's running state
 func (c *DockerContainer) State(ctx context.Context) (*types.ContainerState, error) {
 	inspect, err := c.inspectRawContainer(ctx)

modules/kafka/kafka.go

@@ -72,7 +72,7 @@ func RunContainer(ctx context.Context, opts ...testcontainers.ContainerCustomize
 							return err
 						}
 
-						ip, err := c.ContainerIP(ctx)
+						hostname, err := c.Hostname(ctx)
 						if err != nil {
 							return err
 						}
@@ -82,7 +82,7 @@ func RunContainer(ctx context.Context, opts ...testcontainers.ContainerCustomize
 							return err
 						}
 
-						scriptContent := fmt.Sprintf(starterScriptContent, host, port.Int(), ip)
+						scriptContent := fmt.Sprintf(starterScriptContent, host, port.Int(), hostname)
 
 						return c.CopyToContainer(ctx, []byte(scriptContent), starterScript, 0o755)
 					},