Skip to content

Commit

Permalink
Fixing depreciated docker hub repo
Browse files Browse the repository at this point in the history
  • Loading branch information
jevy committed Feb 23, 2025
1 parent c6e92ff commit 2bc3e71
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down

0 comments on commit 2bc3e71

Please sign in to comment.