kafka管理客户端不提供创建紧急停堆凭证的方法，我所做的是将kafka二进制文件下载到我的节点上，并使用java中的进程运行上面的命令。

Process process = new  ProcessBuilder(new String[] {"bash", "-c", cmdline})
                        .redirectErrorStream(true)
                        .directory(new File(directory))
                        .start();