在Java程序中运行Logstash

我已经在 ElasticSearch 中创建了索引和字段。 我可以使用以下命令成功运行 Logstash 配置文件，将 MySQL 数据库表中的数据添加到 ElasticSearch 中：

bin/logstash -f [PATH TO LOGSTASH CONFIG FILE] -v

我需要从我的 Java 源代码运行此命令。如何从 Java 代码运行此 Logstash 配置文件？

import java.io.*;
class UserTest{
        public static void main(String[] args)
        {
                try
                {
                        String s = "";
                        String[] cmd = new String[]{"/bin/sh", "./logstash","-f","loggingConfFile.conf"};
                        Process processes = Runtime.getRuntime().exec(cmd);
                        BufferedReader stdInput = new BufferedReader(new InputStreamReader(processes.getInputStream()));
                        while ((s = stdInput.readLine()) != null)
                        {
                                System.out.println(s);
                        }
                }
                catch(Exception ex)
                {
                        ex.printStackTrace();
                }
        }
}