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<TestRecord> {
         val adminClient = AdminClientWrapper(bootstrapServers)
         adminClient.createTopics(topic)