feature(ADS-3007): add JAVA_HOME/bin to PATH env variable

cmd/ad-runtime-utils/app.go

@@ -149,6 +149,7 @@ func startService(service string, envName string, envPath string, cfg config.Con
 		srvConfig.EnvVars = make(map[string]string)
 	}
 	srvConfig.EnvVars[envName] = envPath
+	srvConfig.EnvVars["PATH"] = fmt.Sprintf("%s/bin:%s", envPath, os.Getenv("PATH"))
 	if !supervise {
 		return exec.RunExecutable(srvConfig.Executable, srvConfig.ExecutableArgs, srvConfig.EnvVars)
 	}

examples/config/kafka.yaml

@@ -1,17 +1,24 @@
-executable: bin/kafka-server-start.sh
-executable_args:
-  - config/server.properties
-runtimes:
-  java:
-    version: "21"
-health_checks:
-  - type: port
-    params:
-      port: 9092
-      timeout: 20
-      protocol: tcp
-  - type: port
-    params:
-      port: 9093
-      timeout: 20
-      protocol: tcp
+services:
+  KAFKA:
+    executable: /usr/lib/kafka/bin/kafka-server-start.sh
+    executable_args:
+      - /usr/lib/kafka/config/server.properties
+    runtimes:
+      java:
+        version: "21"
+    env_vars:
+      KAFKA_OPTS: "-DZstdTempFolder=/usr/lib/kafka/tmp -Dorg.xerial.snappy.tempdir=/usr/lib/kafka/tmp -Djava.io.tmpdir=/var/tmp"
+      LOG_DIR: "/var/log/kafka"
+      PID_DIR: "/var/run/kafka"
+      JMX_PORT: "9999"
+    health_checks:
+      - type: port
+        params:
+          port: 9092
+          timeout: 20
+          protocol: tcp
+      - type: port
+        params:
+          port: 9093
+          timeout: 20
+          protocol: tcp

internal/exec/exec.go

@@ -3,13 +3,16 @@ package exec
 import (
 	"context"
 	"fmt"
+	"os"
 	"os/exec"
 )
 
 // RunExecutableAsync starts the given service with the provided arguments in a non-blocking way.
 func RunExecutableAsync(executablePath string, args []string, envVars map[string]string) (*exec.Cmd, error) {
 	ctx := context.TODO()
 	cmd := exec.CommandContext(ctx, executablePath, args...)
+	cmd.Stdout = os.Stdout
+	cmd.Stderr = os.Stderr
 
 	// Add environment variables to the command.
 	for k, v := range envVars {