kafka启动、停止命令
- 说明:kafka命令操作,首先进入到kafka的bin目录下。
- 先启动zookeeper:
./zookeeper-server-start.sh config/zookeeper.properties &,启动zookeeper(&是为了能退出命令行)
zookeeper-server-start.sh config/zookeeper.properties
- 检查ZooKeeper状态:
zkServer.sh status
- 再启动kafka服务:
./kafka-server-start.sh ../config/server.properties
- 进程守护模式启动kafka:
nohup ./kafka-server-start.sh ../config/server.properties >/dev/null 2>&1 &
查看端口确保启动成功
- 查看端口:
netstat -tunlp|egrep "(2181|9092)"
- 或者
netstat -nltp
- 或者
netstat -nltp | grep 2181 netstat -nltp | grep 9092
- 或者单独查看9092端口:
netstat -ant | grep 9092
- Kafka关闭命令(备注:先进入kafka目录):
./kafka-server-stop.sh ../config/server.properties
- 关闭zookeeper:
./zookeeper-server-stop.sh config/zookeeper.properties
注意:一定要先启动ZooKeeper 再启动Kafka 顺序不可以改变。
先关闭kafka ,再关闭zookeeper
kafka 生产者命令
- 查看有哪些主题:
./kafka-topics.sh --list --zookeeper zk服务IP:2181
- 创建topic:
./kafka-topics.sh --create --zookeeper zk服务IP:2181 --replication-factor 1 --partitions 1 --topic WordCount
- 查看topic的详细信息:
./kafka-topics.sh -zookeeper zk服务IP:2181 -describe -topic WordCount
- kafka生产者客户端命令:
./kafka-console-producer.sh --broker-list kafka服务IP:9092 --topic WordCount
- kafka消费者客户端命令:
./kafka-console-consumer.sh -zookeeper zk服务IP:2181 --from-beginning --topic WordCount
- 删除topic:
./kafka-topics.sh --zookeeper zk服务IP:2181 --delete --topic WordCount
(注:不能真正删除topic只是把这个topic标记为删除(marked for deletion),要彻底把topic删除必须把kafka中与当前topic相关的数据目录和zookeeper中与当前topic相关的路径一并删除。)