zoukankan      html  css  js  c++  java
  • kafka命令


    查看所有topic: kafka-topics.sh --zookeeper hadoop102:2181 --list


    查看具体的topic : kafka-topics.sh --zookeeper hadoop102:2181 --describe --topic first


    创建topic : kafka-topics.sh --zookeeper hadoop102:2181 --create --replication-factor 3
    --partitions 1 --topic first

    注意:①.partition可以有多个 ②副本的数量不能大于broker的数量

    删除topic : kafka-topics.sh --zookeeper hadoop102:2181 --delete --topic first


    创建生产者:kafka-console-producer.sh --broker-list hadoop102:9092 --topic first


    创建消费者 : kafka-console-consumer.sh --bootstrap-server hadoop102:9092 --topic first


    修改分区数 : kafka-topics.sh --zookeeper hadoop102:2181 --alter --topic first --partitions 6


    指定消费的partition : kafka-console-consumer.sh --bootstrap-server hadoop102:9092
    --topic aa2 --from-beginning --partition 1
    注意 :
    1.如果不指明partition那么所有的partition都会消费
    2.--from-beginning : 从头开始消费
    (如果指明了partition那么就是从这个partition的头消费这一个partition)


    kafka-console-consumer.sh --bootstrap-server hadoop102:9092
    --topic aa2 --partition 0 --offset earliest

    --------------------------------------------------------------------------------------------

  • 相关阅读:
    e.g.-basic-Si
    Telephone interview with Youyou Tu
    Mo2C-tag
    Usage of “symmetrical” and “symmetric”
    Xcrysden-2
    The partial charge density (1)
    利用 AWK 的数值计算功能提升工作效率(转载)
    扩展程序
    选择排序
    装饰递归函数
  • 原文地址:https://www.cnblogs.com/shan13936/p/13935226.html
Copyright © 2011-2022 走看看