class KafkaContainerWrapper extends KafkaContainer { | |
private static KafkaContainerWrapper CONTAINER | |
private KafkaContainerWrapper(String confluentPlatformVersion) { | |
super(confluentPlatformVersion) | |
} | |
static KafkaContainer getContainer() { | |
if (CONTAINER == null) { | |
CONTAINER = new KafkaContainerWrapper("5.3.0") | |
.withReuse(true) | |
.withNetwork(null) | |
.withLabel("com.example.my.application.name", "testcontainersReuseSample") | |
CONTAINER.start() | |
} | |
CONTAINER | |
} | |
} |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment