准备:启动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