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

  • 相关阅读:
    React-Native: bios打开VT-x选项
    React-Native:解决真机调试时候Could not get BatchedBridge, make sure your bundle is packaged properly
    node.js异步编程的几种模式
    第29章 电容触摸屏—触摸画板
    第28章 LTDC—液晶显示中英文
    第27章 LTDC/DMA2D—液晶显示
    第26章 FMC—扩展外部SDRAM
    第25章 串行FLASH文件系统FatFs
    第24章 QSPI—读写串行FLASH
    第23章 I2C—读写EEPR
  • 原文地址:https://www.cnblogs.com/zf201149/p/11610668.html
Copyright © 2011-2022 走看看