设为首页 加入收藏

TOP

zookeeper 和 kafka 常用的命令
2019-05-02 02:28:07 】 浏览:45
Tags:zookeeper kafka 常用 命令
  • zookeeper 常用的命令

  • 连接登陆到zookeeper

bin/zkCli.sh -server localhost:2181

此时,输入“help”可以查看命令参数:

  • 2.“ls path”用于查看路径path下的所有直接子节点:

  • 3. create path data”用于在path路径下创建一个新节点,携带数据data。
  • 例如,在根节点下新建一个名为“myNode”节点,存储的数据为“HelloWorld”:

  • 4. get path 获取节点下的数据 eg: get /mynode

除了返回节点存储的数据之外,还有一系列的元信息,如代表节点创建时间的“cZxid”、“ctime”(两种表示方法);节点的修改时间“mZxid”、“mtime”等。

  • 5. set path data 修改数据,
  • set /mynode dong

  • 6. delete path 删除节点

7. 节点状态的查询,查看节点是follower 还是 leader

  • kafka 常用的命令

  • Zookeeper 启动

bin/zookeeper-server-start.sh -daemon config/zookeeper.properties

  • kafka启动

./bin/kafka-server-start.sh config/server.properties

  • 使用kafka-topics.sh创建单分区单副本的 topic test1:

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test1

  • 查看 topic 列表:

bin/kafka-topics.sh --list --zookeeper localhost:2181

  • 使用kafka-console-producer.sh发送消息:

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test1

  • 使用kafka-console-consumer.sh 接受消息:

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test1 --from-beginning

  • 查看描述 topics 信息

bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test1

同样一个终端下面,不同的窗口,ctrl+tab 切换

】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
上一篇kafka-topics.sh --describe &nbs.. 下一篇golang   将kafka的offset置..

最新文章

热门文章

Hot 文章

Python

C 语言

C++基础

大数据基础

linux编程基础

C/C++面试题目