diff --git a/src/transform-sdk/tests/test_util.go b/src/transform-sdk/tests/test_util.go index fef0a8ed2a08c..1c88c216ef787 100644 --- a/src/transform-sdk/tests/test_util.go +++ b/src/transform-sdk/tests/test_util.go @@ -49,15 +49,16 @@ func (lc *stdoutLogConsumer) Accept(l testcontainers.Log) { // startRedpanda runs the Redpanda binary with a data transforms enabled. func startRedpanda(ctx context.Context) (*redpanda.Container, context.CancelFunc) { - redpandaContainer, err := redpanda.RunContainer(ctx, + redpandaContainer, err := redpanda.Run( + ctx, + "redpandadata/redpanda-nightly:latest", testcontainers.WithLogger(log.Default()), - testcontainers.WithImage("redpandadata/redpanda-nightly:latest"), testcontainers.CustomizeRequestOption(func(req *testcontainers.GenericContainerRequest) error { if req.LogConsumerCfg == nil { req.LogConsumerCfg = &testcontainers.LogConsumerConfig{} } // Uncomment this to get broker logs - // req.LogConsumerCfg.Consumers = append(req.LogConsumerCfg.Consumers, &stdoutLogConsumer{}) + req.LogConsumerCfg.Consumers = append(req.LogConsumerCfg.Consumers, &stdoutLogConsumer{}) return nil }), redpanda.WithEnableWasmTransform(),