zoukankan      html  css  js  c++  java
  • Kafka Zookeeper 基本命令示例

     

    Kafka

    新建Topic

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

    查看已存在Topic列表

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

    查看指定Topic状态

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


    启动Consumer读取消息并输出到标准输出

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


    运行Producer并将Terminal输入的消息发送到服务端

    bin/kafka-console-producer.sh --broker-list localhost:9092 --topic my-topic
    
    << This is a messageThis is another message

    性能测试

    bin/kafka-producer-perf-test.sh --messages 500000 --message-size 1000 --batch-size 500 --topics test --threads 2 --broker-list localhost:9092
    
    bin/kafka-consumer-perf-test.sh --zookeeper localhost:2181 --messages 500000 --topic test --threads 1

    Zookeeper

    启动ZK服务

    bin/zkServer.sh start

    查看ZK服务状态

    bin/zkServer.sh status

    停止ZK服务

    bin/zkServer.sh stop

    重启ZK服务

    bin/zkServer.sh restart

    连接服务器

    bin/zkCli.sh -server 127.0.0.1:2181

    查看根目录

    ls /


    创建 testnode节点

    create /zk/testnode "test"

    查看节点内容

    get /zk/testnode


    设置节点内容

    set /zk/testnode test

    删除节点

    delete /zk/testnode
  • 相关阅读:
    HttpClient——POST请求方法
    【Httpclient+TestNG】接口自动化测试——GET请求示例
    一些杂碎的小知识点
    搭建linux服务器的环境
    javase(1)
    事务处理
    数据库优化
    表单重复提交--->使用Session防止表单重复提交
    两个小程序
    java基础小知识(2)
  • 原文地址:https://www.cnblogs.com/rilley/p/5438188.html
Copyright © 2011-2022 走看看