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

    //查看所有的topic

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

    //创建一个demo的topic

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

    //删除topic ,注意server.properties中delete.topic.enable=true auto.create.topics.enable=false

    ./kafka-topics.sh --zookeeper localhost:2181 --delete --topic demo

    //在控制台中启动生产者

    bin/kafka-console-producer.sh --broker-list 192.168.3.8:9092 --topic demo --producer.config config/producer.properties

    //在控制台中启动消费者

    bin/kafka-console-consumer.sh --bootstrap-server 192.168.3.8:9092 --topic demo --from-beginning --consumer.config config/consumer.properties

    注意:加上权限后:

    producer.properties/consumer.properties中需要加入security.protocol=SASL_PLAINTEXT
    sasl.mechanism=PLAIN,并且注意bootstrap.servers的配置,如果一直配置的是ip,则此处也要填上ip地址,否则执行命令会报错

    # 无权限版本查询(ConsumerOffsetChecker)
    ./kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper 192.168.100.85:2181 --group test --topic hello-sean

    # 无权限版本查询(GetOffsetShell)
    ./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 192.168.100.87:9093 --topic hello-sean --time -1

    # 含权限版本查询
    ./kafka-consumer-groups.sh --bootstrap-server 192.168.100.87:9093,192.168.100.88:9093,192.168.100.89:9093 --command-config ../config/consumer.properties --list

    # 查询单个consumer group
    ./kafka-consumer-groups.sh --bootstrap-server 192.168.100.87:9093 --command-config ../config/consumer.properties --describe --group 'console-consumer-93774'

    # 使用脚本新生产一个consumer group(为了方便查询)
    ./kafka-console-consumer.sh  --bootstrap-server 192.168.100.87:9093,192.168.100.88:9093,192.168.100.89:9093  --topic hello-sean --consumer.config ../config/consumer.properties --new-consumer

    本机zookeeper: root用户装的,安装在路径:/opt/zookeeper中

    启动脚本:./zkServer.sh start

    ./zkServer.sh start-foreground 错误显示在前台中

  • 相关阅读:
    com.android.ide.common.process.PrecessException:org.gradle.process....finished with non-zero exit value 1
    android 学习笔记(1)
    C#遍历指定文件夹中的所有文件(转)
    让TextView里面的文字逐个显示的动画效果实现(1)
    This Handler class should be static or leaks might occur(null) 解决办法 (转)
    Android开发 旋转屏幕导致Activity重建解决方法(转)
    SQLite 数据库
    【Android】error opening trace file: No such file or directory (2)
    WPF中的RichTextBox
    android中的 Toast 和 AlertDialog
  • 原文地址:https://www.cnblogs.com/zf201149/p/11610668.html
Copyright © 2011-2022 走看看