kafka_2.12-2.4.x集群-启动、停止

准备:启动zookeeper

因为 kafka 依赖 zookeeper,所以需要事先启动 zookeeper

启动参见:zookeeper-3.4.x集群:启动、停止服务、查看服务状态、jps

如果zk配置启动脚本,参见:zookeeper-3.4.x集群:启动、停止脚本

登录 hadoop1 启动 kafka

进入 /program/kafka_2.12-2.4.1/ 目录:

cd /program/kafka_2.12-2.4.1/

启动

2种启动方式,都可以

启动命令一:
bin/kafka-server-start.sh -daemon config/server.properties

解释:

  • -daemon:后台启动
启动命令二:
nohup bin/kafka-server-start.sh -daemon config/server.properties &

jps查看

执行 jps 命令,查看下面进程,说明启动成功:

kafka

查看日志

tail -n50 -f /program/kafka_2.12-2.4.1/logs/kafkaServer.out

登录 hadoop2 启动 kafka

进入 /program/kafka_2.12-2.4.1/ 目录:

cd /program/kafka_2.12-2.4.1/

启动

2种启动方式,都可以

启动命令一:
bin/kafka-server-start.sh -daemon config/server.properties

解释:

  • -daemon:后台启动
启动命令二:
nohup bin/kafka-server-start.sh -daemon config/server.properties &

jps查看

执行 jps 命令,查看下面进程,说明启动成功:

kafka

查看日志

tail -n50 -f /program/kafka_2.12-2.4.1/logs/kafkaServer.out

登录 hadoop3 启动 kafka

进入 /program/kafka_2.12-2.4.1/ 目录:

cd /program/kafka_2.12-2.4.1/

启动

2种启动方式,都可以

启动命令一:
bin/kafka-server-start.sh -daemon config/server.properties

解释:

  • -daemon:后台启动
启动命令二:
nohup bin/kafka-server-start.sh -daemon config/server.properties &

jps查看

执行 jps 命令,查看下面进程,说明启动成功:

kafka

查看日志

tail -n50 -f /program/kafka_2.12-2.4.1/logs/kafkaServer.out

验证集群是否启动成功

登录 hadoop1 ,执行下面命令,分别查看其他 kafka 中的主题,当前是空的,所以打印是空的,没报错,就说集群启动成功

bin/kafka-topics.sh --bootstrap-server hadoop1:9092 --list
bin/kafka-topics.sh --bootstrap-server hadoop2:9092 --list
bin/kafka-topics.sh --bootstrap-server hadoop3:9092 --list

停止

执行下面命令:

bin/kafka-server-stop.sh

原文出处:/show_1IX1zupVUuaa.html