.withListener(() -> "kafka:9999")
.withEnv("KAFKA_NUM_PARTITIONS", "10")
.withKraft()
- .waitingFor(Wait.forLogMessage(".*Kafka Server started.*\\n", 1))
+ .waitingFor(Wait.forLogMessage(".*Kafka\\ Server\\ started.*\\n", 1))
.withLogConsumer(new Slf4jLogConsumer(log, true).withPrefix("KAFKA"));
@Container
"--chat.backend.kafka.haproxy-map=/usr/local/etc/haproxy/sharding.map"
)
.dependsOn(kafka)
- .waitingFor(Wait.forHttp("/actuator/health"))
+ .waitingFor(Wait.forLogMessage(".*Started\\ ChatBackendApplication.*\\n", 1))
.withLogConsumer(new Slf4jLogConsumer(log, true).withPrefix("BACKEND-1"));
@Container
"--chat.backend.kafka.haproxy-map=/usr/local/etc/haproxy/sharding.map"
)
.dependsOn(kafka)
- .waitingFor(Wait.forHttp("/actuator/health"))
+ .waitingFor(Wait.forLogMessage(".*Started\\ ChatBackendApplication.*\\n", 1))
.withLogConsumer(new Slf4jLogConsumer(log, true).withPrefix("BACKEND-2"));
@Container
"--chat.backend.kafka.haproxy-map=/usr/local/etc/haproxy/sharding.map"
)
.dependsOn(kafka)
- .waitingFor(Wait.forHttp("/actuator/health"))
+ .waitingFor(Wait.forLogMessage(".*Started\\ ChatBackendApplication.*\\n", 1))
.withLogConsumer(new Slf4jLogConsumer(log, true).withPrefix("BACKEND-3"));
@Container