啟動kafka
sh kafka-server-start.sh -daemon ../config/server.properties
停止kafka
sh kafka-server-stop.sh -daemon ../config/server.properties
啟動kafka自帶zookeeper
sh zookeeper-server-start.sh ../config/zookeeper.properties
停止kafka自帶zookeeper
sh zookeeper-server-stop.sh ../config/zookeeper.properties
查看所有groupid
sh kafka-consumer-groups.sh --new-consumer --bootstrap-server 172.21.51.109:9092 --list
查看指定groupid的詳細資訊
sh kafka-consumer-groups.sh --new-consumer --bootstrap-server 172.21.51.109:9092 --group point_expire_group --describe
查看zookeeper上所有的topic
sh kafka-topics.sh --list --zookeeper 172.21.51.109:2181
查看指定topic的資訊
sh kafka-topics.sh --describe --zookeeper 172.21.51.109:2181 --topic point_expire_topic
創建topic(partitions為磁區數量，replications-factor為副本數量，zookeeper為集群地址，多個可用，隔開)
sh kafka-topics.sh --create --topic point_expire_topic --partitions 2 --replication-factor 3 --zookeeper 172.21.51.108:2181,172.21.51.109:2181,172.21.51.110:2181
洗掉topic
sh kafka-topics.sh --delete --zookeeper 172.21.51.108:2181,172.21.51.109:2181,172.21.51.110:2181 --topic point_expire_topic
修改topic日志存盤時間，無需重啟
ms 時間單位為毫秒值
sh kafka-topics.sh --topic point_expire_topic --zookeeper 172.21.51.108:2181,172.21.51.109:2181,172.21.51.110:2181 --alter --config retention.ms=86400000?
啟動zookeeper服務
./zkServer.sh start
查看zookeeper服務狀態
./zkServer.sh status
停止zookeeper服務
./zkServer.sh stop
重啟zookeeper服務
./zkServer.sh restart
連接zookeeper服務器
./zkCli.sh
轉載請註明出處，本文鏈接：https://www.uj5u.com/qita/431067.html
標籤：其他
上一篇：為什么要做數倉分層，不做行嗎？