zoukankan      html  css  js  c++  java
  • Kafka命令行操作

    Kafka命令行操作

    1)查看当前服务器中的所有topic

    [bingo@hadoop101 kafka]$ bin/kafka-topics.sh --list --zookeeper hadoop101:2181

    2)创建topic

    [bingo@hadoop101 kafka]$ bin/kafka-topics.sh --create --zookeeper hadoop101:2181 --replication-factor 3 --partitions 1 --topic first

    选项说明:

    --topic 定义topic名

    --replication-factor  定义副本数

    --partitions  定义分区数

    3) 删除topic

    [bingo@hadoop101 kafka]$ bin/kafka-topics.sh --delete --zookeeper hadoop101:2181 --topic first

    需要server.properties中设置delete.topic.enable=true否则只是标记删除或者直接重启。

    4)发送消息

    [bingo@hadoop101 kafka]$ bin/kafka-console-producer.sh --broker-list hadoop101:9092 --topic first

    >hello world

    >atguigu  atguigu

    5)消费消息

    [bingo@hadoop102 kafka]$ bin/kafka-console-consumer.sh --zookeeper hadoop101:2181 --from-beginning --topic first

    6)查看某个Topic的详情

    [bingo@hadoop101 kafka]$ bin/kafka-topics.sh --topic first --describe --zookeeper hadoop101:2181
    

      

  • 相关阅读:
    podfile 文件写法
    九大内置对象
    动态网页开发基础
    表单效验
    使用jQuery快速高效制作网页交互特效
    使用jQuery操作DOM
    jQuery选择器
    初始jQuery
    javaScript基础及初始面向对象
    JavaScript操作DOM对象
  • 原文地址:https://www.cnblogs.com/alexzhang92/p/10892743.html
Copyright © 2011-2022 走看看