基本操作
功能说明 | 命令脚本 |
当前znode中所包含的内容 | ls / |
创建普通节点(前面是节点的路径，后面是值） | create /bigdata/flink "flink" |
获取节点的值 | get /bigdata |
修改节点的值 | set /bigdata/flink "flinksql" |
删除节点 | delete /bigdata/flink |
递归删除节点 | rmr /bigdata |
四字母命令
命令 | 功能说明 | 例子 |
conf | zk服务配置的详细信息 | echo conf | nc 127.0.0.1 2181 |
stat | 客户端与zk连接的简要信息 | 参考上面 |
srvr | zk服务的详细信息 | 参考上面 |
cons | 客户端与zk连接的详细信息 | 参考上面 |
mntr | zk服务目前的性能状况 | 参考上面 |
crst | 重置当前的所有连接、会话 | 参考上面 |
dump | 列出未经处理的会话和连接信息 | 参考上面 |
envi | 列出zk的版本信息、主机名称、Java版本、服务器名称等等 | 参考上面 |
ruok | 测试服务器是否正在运行，如果在运行返回imok，否则返回空 | 参考上面 |
srst | 重置Zookeeper的所有统计信息 | 参考上面 |
wchs | 列出watch的总数，连接数 | 参考上面 |
wchp | 列出所有watch的路径及sessionID | 参考上面 |
mntr | 列出集群的关键性能数据，包括zk的版本、node数量、临时节点数等等 | 参考上面 |
Kafka
注: 这里机器我只写一个。命令你们也可使用 ./bin/xx.sh (如：./bin/kafka-topics.sh)
查看当前服务器中的所有topic
kafka-topics --zookeeper xxxxxx:2181 --list --exclude-internal
说明：
exclude-internal：排除kafka内部topic
比如： --exclude-internal --topic "test_.*"创建topic
kafka-topics --zookeeper xxxxxx:2181 --create
--replication-factor
--partitions 1
--topic topic_name
说明：
--topic 定义topic名
--replication-factor 定义副本数
--partitions 定义分区数删除topic
注意: 需要server.properties中设置delete.topic.enable=true否则只是标记删除
kafka-topics --zookeeper xxxxxx:2181 --delete --topic topic_name
