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 7ad427e..e2d2575 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:v23.2.16") { +class TestKafka : RedpandaContainer("docker.redpanda.com/vectorized/redpanda:v23.2.19") { fun produceRecords(topic: String, encoding: String, vararg records: TestRecord): List { val adminClient = AdminClientWrapper(bootstrapServers) adminClient.createTopics(topic)