From 2bc3e71c9928cc81815585b4f14aa95c44ed6e2e Mon Sep 17 00:00:00 2001 From: jevin Date: Sun, 23 Feb 2025 14:12:43 -0500 Subject: [PATCH] Fixing depreciated docker hub repo --- libs/testing/src/main/kotlin/io/typestream/testing/TestKafka.kt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/libs/testing/src/main/kotlin/io/typestream/testing/TestKafka.kt b/libs/testing/src/main/kotlin/io/typestream/testing/TestKafka.kt index 0d4677c..670f884 100644 --- a/libs/testing/src/main/kotlin/io/typestream/testing/TestKafka.kt +++ b/libs/testing/src/main/kotlin/io/typestream/testing/TestKafka.kt @@ -5,7 +5,7 @@ import io.typestream.testing.kafka.KafkaProducerWrapper import io.typestream.testing.model.TestRecord import org.testcontainers.redpanda.RedpandaContainer -class TestKafka : RedpandaContainer("docker.redpanda.com/vectorized/redpanda:v24.2.9") { +class TestKafka : RedpandaContainer("docker.redpanda.com/redpandadata/redpanda:v24.2.9") { fun produceRecords(topic: String, encoding: String, vararg records: TestRecord): List { val adminClient = AdminClientWrapper(bootstrapServers) adminClient.createTopics(topic)