史上最强之安装Kafka并启动Zookeeper和Kafka_Java

1. 安装前准备：

确保已经安装java development kit (jdk)。
下载kafka的二进制文件：https://kafka.apache.org/downloads。

2. 解压kafka压缩包至指定目录。

string kafkadir = "/path/to/kafka";
string kafkazipfile = "/path/to/kafka/kafka_2.13-2.7.0.tgz";
string kafkaextractcmd = "tar -xzf " + kafkazipfile + " -c " + kafkadir;
process process = runtime.getruntime().exec(kafkaextractcmd);
process.waitfor();

3. 修改配置文件：

修改zookeeper配置文件 zookeeper.properties：

string zookeeperconfigfile = kafkadir + "/config/zookeeper.properties";
string zookeeperconnectconfig = "localhost:2181";
files.write(paths.get(zookeeperconfigfile), ("datadir=/tmp/zookeeper\n" +
                                            "clientport=2181\n" +
                                            "maxclientcnxns=0\n" +
                                            "server.1=" + zookeeperconnectconfig).getbytes());

修改kafka配置文件 server.properties：

string kafkaconfigfile = kafkadir + "/config/server.properties";
string zookeeperconnectconfig = "localhost:2181";
string kafkabrokerid = "0";
files.write(paths.get(kafkaconfigfile), ("broker.id=" + kafkabrokerid + "\n" +
                                         "zookeeper.connect=" + zookeeperconnectconfig + "\n" +
                                         "log.dirs=/tmp/kafka-logs").getbytes());

string kafkalogdir = "/tmp/kafka-logs";
string zookeeperdatadir = "/tmp/zookeeper";
new file(kafkalogdir).mkdirs();
new file(zookeeperdatadir).mkdirs();

5. 启动zookeeper：

string zookeeperstartupcmd = kafkadir + "/bin/zookeeper-server-start.sh " +
                             kafkadir + "/config/zookeeper.properties";
process zookeeperprocess = runtime.getruntime().exec(zookeeperstartupcmd);

6. 启动kafka：

string kafkastartupcmd = kafkadir + "/bin/kafka-server-start.sh " +
                         kafkadir + "/config/server.properties";
process kafkaprocess = runtime.getruntime().exec(kafkastartupcmd);