zoukankan      html  css  js  c++  java
  • kafka常用的命令

    1、启动zookeeper

    # ./zkServer.sh start
    

    2、查看zookeeper是否启动

    # ps -ef |grep java
    

    3、关闭zookeeper

    # ./zkServer.sh stop
    

    4、查看zookeeper的状态

    # ./zkServer.sh status
    

    5、启动kafka

    # ./kafka-server-start.sh -daemon ../config/server.properties &
    

    6、查看kafka是否启动

    # ps -ef |grep kafka
    

    7、关闭kafka

    # ./kafka-server-stop.sh
    

    8、创建topic

    # ./kafka-topics.sh --create --zookeeper 172.16.218.201:2181,172.16.218.202:2181,172.16.218.203:2181 --replication-factor 3 --partitions 1 --topic szy
    

    9、查看所有topic

    # ./kafka-topics.sh --list --zookeeper 172.16.218.201:2181,172.16.218.202:2181,172.16.218.203:2181 
    

    10、查看某个topic具体信息

    # ./kafka-topics.sh --describe --zookeeper 172.16.218.201:2181,172.16.218.202:2181,172.16.218.203:2181 --topic szy
    

    11、删除topic (可直接删除的前提:delete.topic.enable=true)

    # ./kafka-topics.sh --delete --zookeeper 172.16.218.201:2181,172.16.218.202:2181,172.16.218.203:2181 --topic test 
    命令无法删除,topic被标记为删除时候,用下面命令删除
    # cd /usr/local/zookeeper-node3/bin/
    # ./zkCli.sh
    ls /brokers/topics
    rmr /brokers/topics/【topic name】
    quit
    

    12、生产消息

    # ./kafka-console-producer.sh --broker-list 172.16.218.201:19092,172.16.218.202:19092,172.16.218.203:19092 --topic szy 
    

    13、消费消息

    # ./kafka-console-consumer.sh --zookeeper 172.16.218.201:2181,172.16.218.202:2181,172.16.218.203:2181  --topic szy --from-beginning
    
  • 相关阅读:
    Java中String的intern方法
    3.7测试复盘
    3.6测试复盘
    LTMU论文解析
    移动机器人相机模型:从相机移动到二维图像
    一步步分析MIPS数据通路(单周期)
    Slam笔记I
    如何理解SiamRPN++?
    如何使用Pytorch迅速写一个Mnist数据分类器
    PySide2的This application failed to start because no Qt platform plugin could be initialized解决方式
  • 原文地址:https://www.cnblogs.com/icyblog/p/7202048.html
Copyright © 2011-2022 走看看