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

    #1.1 kafka启动命令
    nohup bin/kafka-server-start.sh config/server.properties &
    #1.2 kafka停止命令
    bin/kafka-server-stop.sh

    #1.3. kafka重启
    systemctl restart kafka

    #2.1 kafka-topic create 创建了一个名为afc_flux 的主题,3个分区,1个副本因子
    ./kafka-topics.sh --zookeeper tdh09:2181,tdh10:2181,tdh11:2181 --create --topic afc_flux --partitions 3 --replication-factor 1

    #2.2 kafka删除 topic 命令
    /root/TDH-Client/kafka/bin/kafka-console-topics.sh --delete --zookeeper 10.50.198.11:2181 --topic test1

    #2.3查看全部的topic列表:
    /root/TDH-Client/kafka/bin/kafka-console-topics.sh --list --zookeeper 10.50.198.11:2181

    #2.4查看topic详情:
    /root/TDH-Client/kafka/bin/kafka-console-topics.sh --describe --zookeeper 10.50.198.11:2181 --topic a05

    #3.kafka生产命令:broker-list(21,22,23....)
    /root/TDH-Client/kafka/bin/kafka-console-producer.sh --broker-list 10.50.198.21:9092 --topic a05
    然后输入消息:例如:112233

    #4.kafka消费命令:
    /root/TDH-Client/kafka/bin/kafka-console-consumer.sh --bootstrap-server 10.50.198.21:9092 --topic a05 --from-beginning

    #5.查看topic接收的消息:
    /root/TDH-Client/kafka/bin/kafka-console-consumer.sh --bootstrap-server 10.50.198.21:9092 --topic a05 --from-beginning

     
  • 相关阅读:
    vmware linux虚拟机连接ip设置
    java图片转byte转string
    javaScript传递参数,参数变化问题
    path和classpath的区别
    本地jar在打包时打入到项目中去
    使用集合来排序
    Unity 学习笔记2
    Unity 学习笔记
    unity3d 基础知识点
    Unity3D中的多线程及使用多线程
  • 原文地址:https://www.cnblogs.com/javalinux/p/15394682.html
Copyright © 2011-2022 走看看