kafka一键启动集群

以你之姓@ 2022-10-26 03:51 241阅读 0赞

我的kafka的3个节点是这样的。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2FwcGxleXVjaGk_size_16_color_FFFFFF_t_70][]

启动kafka集群脚本

#!/bin/bash
    echo "kafka cluster start"
    ssh Desktop "source ~/.bashrc;$KAFKA/bin/kafka-server-start.sh -daemon $KAFKA/config/server.properties &"
    ssh Laptop "source /home/appleyuchi/.bashrc;$KAFKA2/bin/kafka-server-start.sh -daemon $KAFKA2/config/server.properties &"
    ssh Laptop "source /home/appleyuchi/.bashrc;$KAFKA3/bin/kafka-server-start.sh -daemon $KAFKA3/config/server.properties &"

关闭kafka集群脚本

#!/bin/bash
    echo "kafka cluster stop"
    ssh Desktop "source /home/appleyuchi/.bashrc;$KAFKA/bin/kafka-server-stop.sh &"
    ssh Laptop "source /home/appleyuchi/.bashrc;$KAFKA2/bin/kafka-server-stop.sh &"
    ssh Laptop "source /home/appleyuchi/.bashrc;$KAFKA3/bin/kafka-server-stop.sh &"

②中脚本运行后，并不会立刻关闭所有节点，

需要等待一段时间才能让所有kafka节点关闭。

# 注意点 #

①bash: : comman排查d not found

检查下脚本中有没有圆角字符的空格

②Desktop登录Laptop,

脚本是在Desktop中执行的，读取的是Desktop中的环境变量

**因此虽然$KAFKA2是属于Laptop的节点，为了Desktop上脚本顺利执行，需要在Desktop的~/.bashrc中设置好$KAFKA2的具体值(这点非常重要，务必注意)。**

否则会导致Reference中各种方案全部失效。

③$KAFKA/bin/kafka-run-class.sh中的开头加入

export JAVA\_HOME="/home/appleyuchi/Java/jdk1.8.0\_144"

并且

# Which java to use
    if [ -z "$JAVA_HOME" ]; then
      JAVA="java"
    else
      JAVA="$JAVA_HOME/bin/java"
    fi

改成

# Which java to use
    if [ -z "$JAVA_HOME" ]; then
      JAVA="$JAVA_HOME/bin/java"
    else
      JAVA="$JAVA_HOME/bin/java"
    fi

# 排查 #

如果无法顺利启动的话，

去$KAFKA/logs

下面查看具体的报错信息。

Reference:

\[1\][启动kafka集群，关闭kafka集群脚本][kafka_kafka](测试失败)

**\[2\][shell脚本启动kafka集群][shell_kafka](shell脚本启动kafka集群，先放着再说)**

\[3\][Kafka集群启动停止脚本][Kafka](测试失败)

\[4\][kafka 集群启动脚本 xkafka][kafka _ xkafka]

\[5\][shell脚本，一次性启动kafka集群][shell_kafka 1]

\[6\][Kafka集群一键启动脚本][Kafka 1]

\[7\][\[资料\] kafka集群设置shell脚本一键启动经验总结][kafka_shell]

\[8\][kafka集群启停脚本][kafka]

\[9\][shell脚本启动kafka集群的多台节点][shell_kafka 2]

\[10\][【4】Kafka集群启动/关闭脚本][4_Kafka]

\[11\][一键启动和关闭zookeeper和kafka集群脚本][zookeeper_kafka]

\[12\][集群自动化启动脚本（kafka，zookeeper，es）][kafka_zookeeper_es]

\[13\][kafka集群启动脚本][kafka 1]

\[14\][Kafka集群设置一键启动/一键停止脚本][Kafka 2]

\[15\][kafka集群开启及关闭脚本参考][kafka 2]

\[16\][kafka集群一键启动shell脚本][kafka_shell 1]

\[17\][Kafka 集群启动关闭脚本][Kafka 3]

\[18\][kafka设置shell脚本文件一键启动和关闭][kafka_shell 2]

\[19\][zoookeeper集群和kafka集群启动快速启动脚本][zoookeeper_kafka]

\[20\][kafka深度研究之路(3)-kafka 与zk 集群启停脚本][kafka_3_-kafka _zk]

\[21\][kafka批量启动、关闭脚本][kafka 3]

\[22\][Linux Shell远程执行命令][Linux Shell](测试失败)

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2FwcGxleXVjaGk_size_16_color_FFFFFF_t_70]: /images/20221024/9ac00c80c935425a855480d757da68b0.png
[kafka_kafka]: https://www.cnblogs.com/guoziyi/p/10300636.html
[shell_kafka]: https://blog.csdn.net/epoch_elysian/article/details/105208228
[Kafka]: https://zhuanlan.zhihu.com/p/92611317
[kafka _ xkafka]: https://www.cnblogs.com/kpwong/p/13768886.html
[shell_kafka 1]: https://blog.csdn.net/qq_38872310/article/details/86630682
[Kafka 1]: http://www.linguangling.com/index.php/archives/13/
[kafka_shell]: https://bbs.elecfans.com/jishu_1849530_1_1.html
[kafka]: https://blog.csdn.net/u012373815/article/details/53727984
[shell_kafka 2]: https://blog.csdn.net/PacosonSWJTU/article/details/111428173
[4_Kafka]: https://www.cnblogs.com/DeepInThought/p/11143981.html
[zookeeper_kafka]: https://blog.csdn.net/weixin_41615494/article/details/79566824
[kafka_zookeeper_es]: https://blog.csdn.net/qq_21451945/article/details/102764683
[kafka 1]: https://blog.csdn.net/chaolovejia/article/details/47313027
[Kafka 2]: https://blog.csdn.net/wzc8961661/article/details/104934218
[kafka 2]: https://blog.csdn.net/wf3612581/article/details/81842529
[kafka_shell 1]: https://blog.csdn.net/qq317968200/article/details/103069948
[Kafka 3]: https://blog.csdn.net/lianghecai52171314/article/details/104984005
[kafka_shell 2]: https://www.codeleading.com/article/83382363462/
[zoookeeper_kafka]: http://www.bubuko.com/infodetail-3666143.html
[kafka_3_-kafka _zk]: https://blog.51cto.com/12445535/2437578
[kafka 3]: https://blog.51cto.com/micheng/2476280?source=dra
[Linux Shell]: https://www.cnblogs.com/softidea/p/6855045.html