Fix Redpanda repo in integration tests (#3236)

Signed-off-by: Mihai Todor <[email protected]>
redpanda-data · Mar 4, 2025 · 9d2f919 · 9d2f919
1 parent 83a56d6
commit 9d2f919
Show file tree

Hide file tree

Showing 4 changed files with 13 additions and 12 deletions.
diff --git 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
@@ -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
@@ -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
@@ -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"},