zoukankan      html  css  js  c++  java
  • Kafka

    基本命令

    --创建一个主题
    bin/kafka-topics.sh --create --bootstrap-server 192.168.31.131:9092 --replication-factor 1 --partitions 1 --topic test
    bin/kafka-topics.sh --create --bootstrap-server 192.168.31.131:9092 --replication-factor 2 --partitions 3 --topic test(复制因子为2,分区为3。表示主题test会创建到三台kafka上,且各持有一份备份)
    --查看所有主题
    bin/kafka-topics.sh --list --bootstrap-server 192.168.31.131:9092 
    --生产者
    bin/kafka-console-producer.sh --broker-list 192.168.31.131:9092 --topic test
    --消费者
    bin/kafka-console-consumer.sh --bootstrap-server 192.168.31.131:9092 --topic test --from-beginning
    --查看消息日志内容(了解)
    bin/kafka-run-class.sh kafka.tools.DumpLogSegments --files /tmp/kafka-logs/test-0/00000000000000000000.log --print-data-log

    --查看消费者分组情况、详细信息、删除分组、查看组员

    bin/kafka-consumer-groups.sh --bootstrap-server 192.168.31.133:9092 --list
    bin/kafka-consumer-groups.sh --bootstrap-server 192.168.31.133:9092 --group 分组名 --describe
    bin/kafka-consumer-groups.sh --bootstrap-server 192.168.31.133:9092 --group 分组名 --delete

    bin/kafka-consumer-groups.sh --bootstrap-server 192.168.31.133:9092  --describe --group 分组名 --members

    使用bin/kafka-consumer-groups.sh --bootstrap-server 192.168.31.133:9092可以查看所有命令的使用。

    "我们所要追求的,永远不是绝对的正确,而是比过去的自己更好"
  • 相关阅读:
    表的设计
    改善C#公共程序类库质量的10种方法和工具
    模块化编程
    Linux centOS本地DNS安装
    C#多线程解决界面卡死问题
    图解JOIN
    轻量级前端MVVM框架avalon
    免费的Visual Studio的插件
    Composite C1是一个.Net平台上开源专业的CMS开源项目
    NDepend 3.0已与Visual Studio集成
  • 原文地址:https://www.cnblogs.com/zomicc/p/12410482.html
Copyright © 2011-2022 走看看