所有操作都要cd到/export/servers/kafka_2.11-1.0.0安装包下操作

 

  • bin目录

    bin目录下有很多shell文件，可以根据需要进行操作

  • Topic命令概览

    可以先看一下关于topic的操作

  • 创建Topic

    创建一个名为test的Topic，有三个分区、两个副本

    bin/kafka-topics.sh --create --zookeeper node01:2181 --replication-factor 2 --partitions 3 --topic test

  • 查看Topic

    bin/kafka-topics.sh --list --zookeeper node01:2181,node02:2181,node03:2181

  • 描述Topic

    bin/kafka-topics.sh --describe --zookeeper node01:2181 --topic test

  • Producer生产数据

    bin/kafka-console-producer.sh --broker-list node01:9092,node02:9092,node03:9092 --topic test

    --broker-list和--topic都是必写命令

  • Consumer消费数据

    bin/kafka-console-consumer.sh --from-beginning --topic test --zookeeper node01:2181,node02:2181,node03:2181

    会提示 Using the ConsoleConsumer with old consumer is deprecated and will be removed in a future major release. Consider using the new consumer by passing [bootstrap-server] instead of [zookeeper].

    也就是说用-bootstrap-server代替zookeeper更好

  • 增加topic分区数

    bin/kafka-topics.sh --zookeeper node01:2181 --alter --topic test --partitons 4

  • 增加配置

    bin/kafka-topics.sh --zookeeper node01:2181 --alter --topic test --config flush.messages=1

  • 删除配置

    bin/kafka-topics.sh --zookeeper node01:2181 --alter --topic test --delete-config flush.messages

  • 删除Topic

    bin/kafka-topics.sh --zookeeper node01:2181 --delete --topic test

最新文章

  1. bzoj1503--treap
  2. qt qml qchart 图表组件
  3. JavaScript对象的chapterIII
  4. Xcode LLDB Debug教程
  5. 测试table数据 winfrom datagridview 点击标头数字排序的时候table 列类型要为数字类型
  6. JAVA fundamentals of exception handling mechanism
  7. Win+R快速打开你的应用程序
  8. 【转】Netty那点事（二）Netty中的buffer
  9. [Git] Github客户端上publish后一直转圈，web上未上传成功
  10. poj3252 Round Numbers
  11. 浅谈jquery关于select框的取值和赋值
  12. js 分割循环
  13. jQuery改造插件，添加回调函数
  14. 新发现IM项目Rabbitim（使用msys或者cygwin编译安装），FileZilla（wxWidget开发）
  15. ModelForm 中选择框的数据 以及 instance 参数
  16. SSL证书申请，如何快速通过SSL文件验证。
  17. win10与centos7的双系统U盘安装（二：安装以及配置centos系统）
  18. 数据仓库专题20-案例篇：电商领域数据主题域模型设计v0.2(改进意见征集中）
  19. 无法连接到localhost.其他信息：用户“sa”登录失败。（MicroSoft Sql Server,错误：18456）
  20. Eclipse Maven项目报错1之JAVA编译版本报错

热门文章

  1. 选择IT行业的自我心得，希望能帮助到各位！（三）失败篇
  2. GeoGebra案例（傅里叶级数的方波）
  3. TcxLookupComboBox
  4. 当文件目录变得杂乱不堪怎么办，python帮你轻松搞定
  5. SpringBoot连接Redis服务出现DENIED Redis is running in protected mode because protected mode is enabled
  6. 落谷 P1734 最大约数和
  7. Maven+JSP+Servlet+JDBC+Redis+Mysql实现的黑马旅游网
  8. 详解 Paths类 与 Files类
  9. VMware15 安装Mac 10.14系统/苹果系统
  10. vector做形参时的三种传参方式