- @Override
- String[] getCommandBackend1()
- {
- return new String[]
- {
- "--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"
- };
- }
-
- @Override
- String[] getCommandBackend2()
- {
- return new String[]
- {
- "--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"
- };
- }