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

    启动zookeeper
    
    bin/zookeeper-server-start.sh config/zookeeper.properties &
    
    启动kafka
    
    bin/kafka-server-start.sh config/server.properties &
    
    停止kafka
    bin/kafka-server-stop.sh
    
    停止zookeeper
    bin/zookeeper-server-stop.sh
    创建topic
    bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
    
    展示topic
    bin/kafka-topics.sh --list --zookeeper localhost:2181
    
    描述topic
    bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic my-replicated-topic
    
    生产者:
    bin/kafka-console-producer.sh --broker-list 130.51.23.95:9092 --topic my-replicated-topic
    
    消费者:
    bin/kafka-console-consumer.sh --zookeeper 130.51.23.95:2181 --topic test --from-beginnin
    删除topic
    bin/kafka-topics.sh --delete --zookeeper 130.51.23.95:2181 --topic topicname

    删除topic中存储的内容
    在config/server.properties中找到如下的位置
       

       删除log.dirs指定的文件目录,然后重新启动就可以了

    
    

      

  • 相关阅读:
    今日小结 5.7
    今日小结 5.2
    今日小结 4.30
    今日小结 4.29
    设计模式 笔记1
    第一次找实习
    Java入门 任务表
    今日小结 4.24
    今日小结 4.18
    今日小结 4.17
  • 原文地址:https://www.cnblogs.com/dragkiss/p/5668019.html
Copyright © 2011-2022 走看看