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可以查看所有命令的使用。

    "我们所要追求的,永远不是绝对的正确,而是比过去的自己更好"
  • 相关阅读:
    uva 11080(二分图染色)
    poj 3255(次短路)
    uva 707(记忆化搜索)
    uva 436(floyd变形)
    uva 11748(求可达矩阵)
    uva 11573(bfs)
    Codeforces Round #226 (Div. 2) 解题报告
    uva 11354(最小瓶颈路--多组询问 MST+LCA倍增)
    uva 534(最小瓶颈路)
    uva 538(简单图论 入度出度)
  • 原文地址:https://www.cnblogs.com/zomicc/p/12410482.html
Copyright © 2011-2022 走看看