-
- static Network NETWORK = Network.newNetwork();
-
- static KafkaContainer KAFKA =
- new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:7.4.0"))
- .withNetwork(NETWORK)
- .withNetworkAliases("kafka")
- .withListener(() -> "kafka:9999")
- .withKraft()
- .waitingFor(Wait.forLogMessage(".*Kafka\\ Server\\ started.*\\n", 1))
- .withLogConsumer(new Slf4jLogConsumer(log, true).withPrefix("KAFKA"));
-
- static GenericContainer BACKEND_1 =
- new GenericContainer(DockerImageName.parse("juplo/chat-backend:0.0.1-SNAPSHOT"))
- .withImagePullPolicy(NEVER_PULL)
- .withNetwork(NETWORK)
- .withNetworkAliases("backend-1")
- .withCommand(
- "--chat.backend.instance-id=backend-1",
- "--chat.backend.services=kafka",
- "--chat.backend.kafka.bootstrap-servers=kafka:9999",
- "--chat.backend.kafka.instance-uri=http://backend-1:8080",
- "--chat.backend.kafka.num-partitions=10",
- "--chat.backend.kafka.client-id-prefix=B1",
- "--chat.backend.kafka.haproxy-runtime-api=haproxy:8401",
- "--chat.backend.kafka.haproxy-map=/usr/local/etc/haproxy/sharding.map"
- )
- .withExposedPorts(8080)
- .dependsOn(KAFKA)
- .waitingFor(Wait.forLogMessage(".*Started\\ ChatBackendApplication.*\\n", 1))
- .withLogConsumer(new Slf4jLogConsumer(log, true).withPrefix("BACKEND-1"));
-
- static GenericContainer BACKEND_2 =
- new GenericContainer(DockerImageName.parse("juplo/chat-backend:0.0.1-SNAPSHOT"))
- .withImagePullPolicy(NEVER_PULL)
- .withNetwork(NETWORK)
- .withNetworkAliases("backend-2")
- .withCommand(
- "--chat.backend.instance-id=backend-2",
- "--chat.backend.services=kafka",
- "--chat.backend.kafka.bootstrap-servers=kafka:9999",
- "--chat.backend.kafka.instance-uri=http://backend-2:8080",
- "--chat.backend.kafka.num-partitions=10",
- "--chat.backend.kafka.client-id-prefix=B2",
- "--chat.backend.kafka.haproxy-runtime-api=haproxy:8401",
- "--chat.backend.kafka.haproxy-map=/usr/local/etc/haproxy/sharding.map"
- )
- .withExposedPorts(8080)
- .dependsOn(KAFKA)
- .waitingFor(Wait.forLogMessage(".*Started\\ ChatBackendApplication.*\\n", 1))
- .withLogConsumer(new Slf4jLogConsumer(log, true).withPrefix("BACKEND-2"));
-
-
- static GenericContainer BACKEND_3 =
- new GenericContainer(DockerImageName.parse("juplo/chat-backend:0.0.1-SNAPSHOT"))
- .withImagePullPolicy(NEVER_PULL)
- .withNetwork(NETWORK)
- .withNetworkAliases("backend-3")
- .withCommand(
- "--chat.backend.instance-id=backend-3",
- "--chat.backend.services=kafka",
- "--chat.backend.kafka.bootstrap-servers=kafka:9999",
- "--chat.backend.kafka.instance-uri=http://backend-3:8080",
- "--chat.backend.kafka.num-partitions=10",
- "--chat.backend.kafka.client-id-prefix=B3",
- "--chat.backend.kafka.haproxy-runtime-api=haproxy:8401",
- "--chat.backend.kafka.haproxy-map=/usr/local/etc/haproxy/sharding.map"
- )
- .withExposedPorts(8080)
- .dependsOn(KAFKA)
- .waitingFor(Wait.forLogMessage(".*Started\\ ChatBackendApplication.*\\n", 1))
- .withLogConsumer(new Slf4jLogConsumer(log, true).withPrefix("BACKEND-3"));
-
- static GenericContainer HAPROXY =
- new GenericContainer(DockerImageName.parse("haproxytech/haproxy-debian:2.8"))
- .withNetwork(NETWORK)
- .withNetworkAliases("haproxy")
- .withClasspathResourceMapping(
- "haproxy.cfg",
- "/usr/local/etc/haproxy/haproxy.cfg",
- BindMode.READ_ONLY)
- .withClasspathResourceMapping(
- "sharding.map",
- "/usr/local/etc/haproxy/sharding.map",
- BindMode.READ_WRITE)
- .withExposedPorts(8400, 8401, 8404)
- .withLogConsumer(new Slf4jLogConsumer(log, true).withPrefix("HAPROXY"));