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

    Kafka命令行操作

    (如果是服务器单独安装的kafka,就进入到xxx.sh所在的路径下,执行以下命令)


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

    [sea@hadoop002 kafka]$ bin/kafka-topics.sh --zookeeper host12:2181 --list

    2)创建topic

    [sea@hadoop002 kafka]$ bin/kafka-topics.sh --zookeeper host12:2181 --create --replication-factor 3 --partitions 1 --topic lrxtest0625

    选项说明:

    --topic 定义topic名

    --replication-factor 定义副本数

    --partitions 定义分区数

    3)删除topic

    [sea@hadoop002 kafka]$ bin/kafka-topics.sh --zookeeper host12:2181 --delete --topic lrxtest0625

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

    4)发送消息

    [sea@hadoop002 kafka]$ bin/kafka-console-producer.sh --broker-list host12:9092 --topic lrxtest0625

    >hello world

    >sea sea

    5)消费消息

    [sea@hadoop103 kafka]$ bin/kafka-console-consumer.sh  --bootstrap-server host12:9092 --from-beginning --topic lrxtest0625

    --from-beginning:会把first主题中以往所有的数据都读取出来。根据业务场景选择是否增加该配置。

     --bootstrap-server:生产消息的服务器

    6)查看某个Topic的详情

    [sea@hadoop002 kafka]$ bin/kafka-topics.sh --zookeeper host12:2181  --describe --topic lrxtest0625

    (如果是CDH中安装的kafka,则直接执行命令即可,CDH已经将命令设为全局作用域了)即:

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

    [sea@hadoop002 kafka]$ kafka-topics --zookeeper host12:2181 --list

     如果CDH中设置了路径,则上述命令要加路径:

     [sea@hadoop002 kafka]$ kafka-topics --zookeeper host12:2181/data2/kafka  --list

    2)创建topic

    [sea@hadoop002 kafka]$ kafka-topics --zookeeper host12:2181/data2/kafka --create --replication-factor 3 --partitions 1 --topic lrxtest0625

    选项说明:

    --topic 定义topic名

    --replication-factor 定义副本数

    --partitions 定义分区数

    3)删除topic

    [sea@hadoop002 kafka]$ kafka-topics --zookeeper host12:2181/data2/kafka --delete --topic lrxtest0625

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

    4)发送消息

    [sea@hadoop002 kafka]$ kafka-console-producer --broker-list host12:9092 --topic lrxtest0625

    >hello world

    >sea sea

    5)消费消息

    [sea@hadoop103 kafka]$ kafka-console-consumer  --bootstrap-server host12:9092 --from-beginning --topic lrxtest0625

    --from-beginning:会把first主题中以往所有的数据都读取出来。根据业务场景选择是否增加该配置。

     --bootstrap-server:生产消息的服务器

    6)查看某个Topic的详情

    [sea@hadoop002 kafka]$ kafka-topics --zookeeper host12:2181/data2/kafka  --describe --topic lrxtest0731

     

    每天进步一点点,快乐生活多一点。
  • 相关阅读:
    PHP 5.5.0 Alpha5 发布
    Ubuntu Touch 只是另一个 Android 皮肤?
    MariaDB 10 已经为动态列提供文档说明
    Percona Toolkit 2.1.9 发布,MySQL 管理工具
    Oracle Linux 6.4 发布
    Ruby 2.0.0 首个稳定版本(p0)发布
    Apache Pig 0.11.0 发布,大规模数据分析
    Node.js 0.8.21 稳定版发布
    红薯 MySQL 5.5 和 5.6 默认参数值的差异
    Django 1.5 正式版发布,支持 Python 3
  • 原文地址:https://www.cnblogs.com/yiruliu/p/13192271.html
Copyright © 2011-2022 走看看