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 错误显示在前台中

  • 相关阅读:
    申论复习路线
    项目管理小拾
    物理隔离卡,双网通用安装
    生成css sprites
    图片压缩
    css预编译 sass
    小杂记
    遮罩层和弹出层(居中)
    布局之并列登高自适应高度解决方案
    slide逻辑
  • 原文地址:https://www.cnblogs.com/zf201149/p/11610668.html
Copyright © 2011-2022 走看看