启动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
