From 9d2f919b29d708afa84e30cffd42f90114db28c8 Mon Sep 17 00:00:00 2001 From: Mihai Todor Date: Tue, 4 Mar 2025 15:34:47 +0000 Subject: [PATCH] Fix Redpanda repo in integration tests (#3236) Signed-off-by: Mihai Todor --- internal/impl/kafka/enterprise/integration_test.go | 3 ++- internal/impl/kafka/integration_franz_test.go | 8 ++++---- internal/impl/kafka/integration_sarama_test.go | 6 +++--- internal/impl/kafka/integration_test.go | 8 ++++---- 4 files changed, 13 insertions(+), 12 deletions(-) diff --git a/internal/impl/kafka/enterprise/integration_test.go b/internal/impl/kafka/enterprise/integration_test.go index 513529745b..a262f75d86 100644 --- a/internal/impl/kafka/enterprise/integration_test.go +++ b/internal/impl/kafka/enterprise/integration_test.go @@ -590,7 +590,7 @@ func startRedpanda(t *testing.T, pool *dockertest.Pool, exposeBroker bool, autoc } options := &dockertest.RunOptions{ - Repository: "redpandadata/redpanda", + Repository: "docker.redpanda.com/redpandadata/redpanda", Tag: "latest", Hostname: "redpanda", Cmd: cmd, @@ -1144,6 +1144,7 @@ output: } func TestRedpandaMigratorTopicConfigAndACLsIntegration(t *testing.T) { + integration.CheckSkip(t) t.Parallel() pool, err := dockertest.NewPool("") diff --git a/internal/impl/kafka/integration_franz_test.go b/internal/impl/kafka/integration_franz_test.go index 9307764ee7..be6464d89d 100644 --- a/internal/impl/kafka/integration_franz_test.go +++ b/internal/impl/kafka/integration_franz_test.go @@ -44,7 +44,7 @@ func TestIntegrationFranz(t *testing.T) { kafkaPortStr := strconv.Itoa(kafkaPort) options := &dockertest.RunOptions{ - Repository: "redpandadata/redpanda", + Repository: "docker.redpanda.com/redpandadata/redpanda", Tag: "latest", Hostname: "redpanda", ExposedPorts: []string{"9092/tcp"}, @@ -213,7 +213,7 @@ func TestIntegrationFranzSasl(t *testing.T) { kafkaPortStr := strconv.Itoa(kafkaPort) options := &dockertest.RunOptions{ - Repository: "redpandadata/redpanda", + Repository: "docker.redpanda.com/redpandadata/redpanda", Tag: "latest", Hostname: "redpanda", ExposedPorts: []string{"9092/tcp"}, @@ -324,7 +324,7 @@ func TestIntegrationFranzOutputFixedTimestamp(t *testing.T) { kafkaPortStr := strconv.Itoa(kafkaPort) options := &dockertest.RunOptions{ - Repository: "redpandadata/redpanda", + Repository: "docker.redpanda.com/redpandadata/redpanda", Tag: "latest", Hostname: "redpanda", ExposedPorts: []string{"9092/tcp"}, @@ -396,7 +396,7 @@ func BenchmarkIntegrationFranz(b *testing.B) { kafkaPortStr := strconv.Itoa(kafkaPort) options := &dockertest.RunOptions{ - Repository: "redpandadata/redpanda", + Repository: "docker.redpanda.com/redpandadata/redpanda", Tag: "latest", Hostname: "redpanda", ExposedPorts: []string{"9092/tcp"}, diff --git a/internal/impl/kafka/integration_sarama_test.go b/internal/impl/kafka/integration_sarama_test.go index 1f0f324238..55ea28b7e7 100644 --- a/internal/impl/kafka/integration_sarama_test.go +++ b/internal/impl/kafka/integration_sarama_test.go @@ -50,7 +50,7 @@ func TestIntegrationSaramaCheckpointOneLockUp(t *testing.T) { kafkaPortStr := strconv.Itoa(kafkaPort) options := &dockertest.RunOptions{ - Repository: "redpandadata/redpanda", + Repository: "docker.redpanda.com/redpandadata/redpanda", Tag: "latest", Hostname: "redpanda", ExposedPorts: []string{"9092/tcp"}, @@ -213,7 +213,7 @@ func TestIntegrationSaramaRedpanda(t *testing.T) { kafkaPortStr := strconv.Itoa(kafkaPort) options := &dockertest.RunOptions{ - Repository: "redpandadata/redpanda", + Repository: "docker.redpanda.com/redpandadata/redpanda", Tag: "latest", Hostname: "redpanda", ExposedPorts: []string{"9092/tcp"}, @@ -676,7 +676,7 @@ func TestIntegrationSaramaOutputFixedTimestamp(t *testing.T) { kafkaPortStr := strconv.Itoa(kafkaPort) options := &dockertest.RunOptions{ - Repository: "redpandadata/redpanda", + Repository: "docker.redpanda.com/redpandadata/redpanda", Tag: "latest", Hostname: "redpanda", ExposedPorts: []string{"9092/tcp"}, diff --git a/internal/impl/kafka/integration_test.go b/internal/impl/kafka/integration_test.go index 79fb667f87..b78e043cf5 100644 --- a/internal/impl/kafka/integration_test.go +++ b/internal/impl/kafka/integration_test.go @@ -112,7 +112,7 @@ func TestIntegrationRedpanda(t *testing.T) { kafkaPortStr := strconv.Itoa(kafkaPort) options := &dockertest.RunOptions{ - Repository: "redpandadata/redpanda", + Repository: "docker.redpanda.com/redpandadata/redpanda", Tag: "latest", Hostname: "redpanda", ExposedPorts: []string{"9092/tcp"}, @@ -265,7 +265,7 @@ func TestIntegrationRedpandaSasl(t *testing.T) { kafkaPortStr := strconv.Itoa(kafkaPort) options := &dockertest.RunOptions{ - Repository: "redpandadata/redpanda", + Repository: "docker.redpanda.com/redpandadata/redpanda", Tag: "latest", Hostname: "redpanda", ExposedPorts: []string{"9092/tcp"}, @@ -373,7 +373,7 @@ func TestIntegrationRedpandaOutputFixedTimestamp(t *testing.T) { kafkaPortStr := strconv.Itoa(kafkaPort) options := &dockertest.RunOptions{ - Repository: "redpandadata/redpanda", + Repository: "docker.redpanda.com/redpandadata/redpanda", Tag: "latest", Hostname: "redpanda", ExposedPorts: []string{"9092/tcp"}, @@ -445,7 +445,7 @@ func BenchmarkIntegrationRedpanda(b *testing.B) { kafkaPortStr := strconv.Itoa(kafkaPort) options := &dockertest.RunOptions{ - Repository: "redpandadata/redpanda", + Repository: "docker.redpanda.com/redpandadata/redpanda", Tag: "latest", Hostname: "redpanda", ExposedPorts: []string{"9092/tcp"},