zoukankan      html  css  js  c++  java
  • kafka查看topic和消息内容命令

    1、查询topic,进入kafka目录:
    bin/kafka-topics.sh --list --zookeeper localhost:2181

    2、查询topic内容:
    bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topicName --from-beginning

    查询topic
    ./bin/kafka-topics.sh --bootstrap-server hadoop102:9092
    创建topic
    ./bin/kafka-topics.sh --bootstrap-server hadoop102:9092 --create --topic first --partitions 4 --replication-factor 2
    查看topic 为 first的 详细信息
    ./bin/kafka-topics.sh --bootstrap-server hadoop102:9092 --describe --topic first
    往topic 为 first 的内部生产消息
    ./bin/kafka-console-producer.sh --broker-list hadoop102:9092 --topic first
    从topic 为first的内部消费消息
    ./bin/kafka-console-consumer.sh --bootstrap-server hadoop102:9092 --topic first

  • 相关阅读:
    Redis学习小结
    抽屉模型
    用户提交数据的验证
    jsonp原理与实验
    文件上传
    项目
    CBV
    C++算法 线段树
    写一些奇怪的东西找到的奇怪的错误
    php安装过程出现的一些错误问题:
  • 原文地址:https://www.cnblogs.com/deepJL/p/15030999.html
Copyright © 2011-2022 走看看