简单的kafka命令行操作
目录
一、主题topic命令行操作
1.查看操作主题的命令参数
2.连接kafka地址，创建名为kaf的主题，指定分区和副本数量
3.查看所有主题的名称
4.查看主题的详细信息
5.修改主题（修改分区数）
二、生产者命令行操作
1.查看操作生产者的命令参数：kafka-console-produce.sh
2.生产一个数据，放到topic kaf中
3.消费者使用数据 slave2 slave3都可
一、主题topic命令行操作
1.查看操作主题的命令参数：kafka-topic.sh
| 参数 | 说明 |
| --bootstrap-server<String: server to connect to> | 设置连接kafka的主机名和端口号 |
| --topic <String: topic> | 设置操作主题的名称 |
| --create | 创建主题 |
| --delete | 删除主题 |
| --alter | 修改主题（修改主题的分区数） |
| --list | 显示所有主题 |
| --describe | 显示指定主题的详细信息 |
| --partitions <Integer: # of partitions> | 设置主题的分区数 |
| partitions <Integer: # of partitions> | 设置分区的副本数量 |
2.连接kafka地址，创建名为kaf的主题，指定分区和副本数量：--bootstrap-server slave2:9092
3.查看所有主题的名称
4.查看主题的详细信息
5.修改主题（修改分区数），只能改更大的，分区数只能增加
二、生产者命令行操作
1.查看操作生产者的命令参数：kafka-console-produce.sh
2.生产一个数据，放到topic kaf中，
3.消费者使用数据 slave2 slave3都可
slave1生产什么slave3消费什么
但是消费者进入前的数据并没有拉取到，应该怎么样才可以把之前的数据拉取到
在slave3中使用该命令即可
简单的kafka命令行操作相关推荐
- kafka 命令行操作大全
kafka 命令行操作大全 一.集群相关常用命令 二.topic相关常用命令 2.1 脚本&参数简介 2.2 举例 三.生产者命令行常用操作 3.1 脚本&参数简介 3.2 举例发送消 ...
- 【kafka】三、kafka命令行操作
kafka命令行操作 kafka的相关操作命令脚本文件在bin目录下 查看所有的topic kafka-topics.sh --zookeeper hll1:2181 --list 或 kafka-t ...
- 数据仓库 — 07_Kafka的安装与部署（Kafka命令行操作指令、Kafka集群群起脚本、压力测试、节点数量计算、hadoop_zookeeper_flume_kafka群起脚本、默认端口总结）
文章目录 1 Kafka的安装与配置 2 Kafka命令行操作 2.1 查看当前服务器中的所有topic 2.2 创建topic 2.3 删除topic 2.4 发送消息 2.5 消费消息 2.6 查 ...
- kafka命令行操作大全
最近利用flink使用一个流式SQL处理平台,利用kafka, mysql, hive等组件比较多,命令行突然间需要操作一次记不住命令很麻烦,索性直接整理成笔记. 在 0.9.0.0 之后的 Kafk ...
- kafka命令行操作
[README] kafka集群 -- kafka集群 3台机器 centos201 192.168.163.201 centos202 192.168.163.202 centos203 192.1 ...
- Kafka 命令行操作
1)查看当前服务器中的所有 topic bin/kafka-topics.sh --zookeeper backup01:2181 使用命令 bin/kafka-topics.sh --list ...
- kafka命令行操作，topic相关命令
查看当前服务器中的所有topic: bin/kafka-topics.sh --zookeeper 主机:2181 --list 创建topic: bin/kafka-topics.sh --zook ...
- 大数据6_03_Kafka命令行操作
3 Kafka命令行操作 总结: # 和topic有关的命令:都使用 kafka-topics-sh --zookeeper hadoop102:2181 + 操作 # 和生产消息有关的:使用brok ...
- kafka _命令行操作
kafka _命令行操作 #启动zk zkServer.start #启动kafka kafka-server-start.sh -daemon /opt/kafka/config/server.pr ...
最新文章
- VMM系列之VMM角色介绍以及创建运行方式账户
- 深入::first-letter的研究
- Windows下常用的100个CMD指令以及常见的操作
- 怎样对流媒体进行压力测试_四合一气体检测仪怎样进行气体测试？
- (hdu 1568) Fibonacci
- YUV444，YUV420P，YUV420SP，YUV422P，YUV422SP，NV12，NV21，NV16，NV61等格式区分与存储简介
- 家庭宽带上网_03_IP城域网
- 论文阅读：《Connectionist Temporal Classification: Labelling Unsegmented Sequence Data with Recurrent Neu》
- 工作-safari时间格式
- 把整个网页下载下来的方法
- cpuz检测硬件真假_难道CPU真的没有真假，只有好坏？
- 微软良心伙伴，OneDrive首发支持iOS11的文件App
- 关于局域网不能访问-共享打印机
- 回溯（python）
- BUPT-CSAPP 期末复习书后参考题节选及评注
- JMM内存模型 多线程三大特性
- CentOS之——双网卡双IP双网关配置(双网卡配置一个上外网一个接局域网)
- javascript中change事件的用法
- Pyhotn3，爬取B站up主的信息！
- cheer ,on the way to linux