zoukankan      html  css  js  c++  java
  • kafka学习笔记--常用指令

    常用指令:

    //新建虚拟窗口 kafka,在每台上执行

    $ screen -S kafka

    // 退出虚拟窗口 kafka,在每台上执行 $ Ctrl+A+D

    1.// 创建 topic

    $ kafka-topics.sh --create --zookeeper cluster1:2181,cluster2:2181,cluster3:2181 --replication-factor 3 --partitions 1 --topic mykafka

    2.// 查看 Topic:

    $ kafka-topics.sh --list --zookeeper cluster1:2181,cluster2:2181,cluster3:2181(此时会显示 Topic:mykafka)

    3.// 查看详细信息

    $ kafka-topics.sh --describe --zookeeper cluster1:2181,cluster2:2181,cluster3:2181

    4.// 发送消息(cluster1 上执行)

    $ kafka-console-producer.sh --broker-list localhost:9092 --topic mykafka

    5.// 接收消息(cluster2 上执行)

    $ kafka-console-consumer.sh -zookeeper cluster1:2181,cluster2:2181,cluster3:2181 --topic mykafka --from-beginning

    // 在 cluster1 输入以下内容

    test

    mycluster test

    可以在 cluster2 上看到相应的信息。

    按 Ctrl+C 退出。

    6.删除话题mykafka

    $ kafka-topics.sh --delete --zookeeper cluster1:2181,cluster2:2181,cluster3:2181 --topic mykafka

  • 相关阅读:
    oracle 数据库关闭的的几种方式总结
    oracle热备份
    oracle 的 startup,startup mount,startup nomount之间的区别
    Oracle数据导入导出imp/exp命令总结
    oracle模糊查询效率可这样提高
    流程控制
    常量
    java序列化
    JVM锁说明
    go变量和数据类型
  • 原文地址:https://www.cnblogs.com/bao-ZhangJiao/p/14268768.html
Copyright © 2011-2022 走看看