in java/showcase/src/main/java/org/apache/flink/statefun/playground/java/showcase/part6/serving/StatefulFunctionsRuntimeProcesses.java [64:80]
public static void main(String[] args) throws Exception {
try {
KAFKA.start();
STATEFUN_MANAGER.start();
Testcontainers.exposeHostPorts(GreeterAppServer.PORT);
STATEFUN_WORKER.start();
KAFKA_JSON_PRODUCER.start();
sleep();
} finally {
KAFKA_JSON_PRODUCER.stop();
STATEFUN_WORKER.stop();
STATEFUN_MANAGER.stop();
KAFKA.stop();
}
}