Skip to content

Commit

Permalink
transform-sdk/tests: Remove usage of deprecated methods
Browse files Browse the repository at this point in the history
  • Loading branch information
rockwotj committed Jul 26, 2024
1 parent b2dcd04 commit 0b9f079
Showing 1 changed file with 4 additions and 3 deletions.
7 changes: 4 additions & 3 deletions src/transform-sdk/tests/test_util.go
Original file line number Diff line number Diff line change
Expand Up @@ -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(),
Expand Down

0 comments on commit 0b9f079

Please sign in to comment.