Kafka 命令行操作
1)查看当前服务器中的所有 topic
bin/kafka-topics.sh --zookeeper backup01:2181
使用命令 bin/kafka-topics.sh --list 报异常,提示必须依赖zookeeper 前面我们就讲过kafka是依赖于zookeeper
连上zookeeper什么都没有输出,因为我们什么消息也没有,我们需要创建topic
bin/kafka-topics.sh --list --zookeeper backup01:2181
2)创建 topic
bin/kafka-topics.sh --zookeeper backup01:2181 --create --replication-factor 3 --partitions 1 -topic first
选项说明:
--topic 定义 topic 名
--replication-factor 定义副本数
--partitions 定义分区数
再次查看
日志分析
backup01
buckup02
buckup03
我们看见之前建立和配置好的logs目录下面生成很多文件 其中有个first-1这个就是我们创建的主题,但是这个主题是主题名字和分区名字联合命名。
还有一个最重要的是就是我们后台启动看不见kafka的启动日志在这个server.log下面我们可以查询启动相关信息
3)删除 topic
bin/kafka-topics.sh --zookeeper backup01:2181 --delete --topic first #需要 server.properties 中设置 delete.topic.enable=true 否则只是标记删除
那我们就设置一下
我们删除了之后重新建立一个first主题 一个分区一个副本
buckup01
buckup02
buckup03
我们发现一个分区一个副本就一个first-0
现在大家应该明白了什么是分区和副本
4)查看某个 Topic 的详情
bin/kafka-topics.sh --zookeeper buckup01:2181 --describe --topic first
上面只有一个分区一个副本,下面我们创建一个secend主题3个分区3个副本,查看下主题的详情
分区0有3个副本
分区1也有3个副本
分区2也有3个副本
我们在创建一个主题three 2个分区2个副本
主题three 分区1的其中1个副本在buckup01机器上
主题three 分区0的其中1个副本被分配在buckup02机器上
主题three 分区0和分区1的另一个副本都在buckup03机器上
讲了这么多估计没有不懂分区和副本了吧
注意有一点:副本数不能超过集群的机器数量
5)发送消息 向主题first发送消息(buckup01开启一个生产者)
bin/kafka-console-producer.sh --brokerlist buckup01:9092 --topic first
>hello world
>atguigu atguigu
6)消费消息 (backup03开启一个消费者)
bin/kafka-console-consumer.sh \ --zookeeper buckup03:2181 --topic first
总是报一个错误:zookeeper is not a recognized option
在新版本--zookeeper是一个过时的方法,此时,才知道原来在最新的版本中,这种启动方式已经被删除了,
最后附上0.90版本之后启动消费者的方法:
bin/kafka-console-consumer.sh --bootstrap-server backup03:9092 --topic first
在backup02在开启一个消费者,此时backup02这个机器是在发消息时候不在线,默认只能从最大开始,想要从头消费需要使用--from-beginning参数
bin/kafka-console-consumer.sh --bootstrap-server backup02:9092 --topic first --from-beginning
我们在看下logs下目录 (主题__consumer_offsets 后面数字是分区 消费者默认50个分区)
[root@backup02 kafka_2.12-2.4.1]# cd logs/
[root@backup02 logs]# ll
total 476
-rw-r--r--. 1 root root 4 Mar 29 16:31 cleaner-offset-checkpoint
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-0
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-12
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-15
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-18
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-21
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-24
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-27
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-3
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-30
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-33
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-36
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-39
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-42
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-45
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-48
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-6
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-9
-rw-r--r--. 1 root root 11302 Mar 29 15:56 controller.log
-rw-r--r--. 1 root root 7243 Mar 29 13:56 controller.log.2020-03-29-13
-rw-r--r--. 1 root root 3499 Mar 29 14:02 controller.log.2020-03-29-14
-rw-r--r--. 1 root root 0 Mar 29 13:46 kafka-authorizer.log
-rw-r--r--. 1 root root 0 Mar 29 13:46 kafka-request.log
-rw-r--r--. 1 root root 17309 Mar 29 17:37 kafkaServer-gc.log.0.current
-rw-r--r--. 1 root root 102388 Mar 29 17:36 kafkaServer.out
-rw-r--r--. 1 root root 1055 Mar 29 16:31 log-cleaner.log
-rw-r--r--. 1 root root 172 Mar 29 13:47 log-cleaner.log.2020-03-29-13
-rw-r--r--. 1 root root 550 Mar 29 14:02 log-cleaner.log.2020-03-29-14
-rw-r--r--. 1 root root 550 Mar 29 15:56 log-cleaner.log.2020-03-29-15
-rw-r--r--. 1 root root 4 Mar 29 17:38 log-start-offset-checkpoint
-rw-r--r--. 1 root root 88 Mar 29 15:56 meta.properties
-rw-r--r--. 1 root root 452 Mar 29 17:38 recovery-point-offset-checkpoint
-rw-r--r--. 1 root root 452 Mar 29 17:39 replication-offset-checkpoint
drwxr-xr-x. 2 root root 141 Mar 29 16:42 secend-0
drwxr-xr-x. 2 root root 141 Mar 29 16:42 secend-1
drwxr-xr-x. 2 root root 141 Mar 29 16:42 secend-2
-rw-r--r--. 1 root root 41838 Mar 29 17:36 server.log
-rw-r--r--. 1 root root 31088 Mar 29 13:57 server.log.2020-03-29-13
-rw-r--r--. 1 root root 40824 Mar 29 14:52 server.log.2020-03-29-14
-rw-r--r--. 1 root root 53272 Mar 29 15:56 server.log.2020-03-29-15
-rw-r--r--. 1 root root 27236 Mar 29 16:56 server.log.2020-03-29-16
-rw-r--r--. 1 root root 36852 Mar 29 17:34 state-change.log
-rw-r--r--. 1 root root 1145 Mar 29 13:51 state-change.log.2020-03-29-13
-rw-r--r--. 1 root root 36058 Mar 29 15:56 state-change.log.2020-03-29-15
-rw-r--r--. 1 root root 16465 Mar 29 16:48 state-change.log.2020-03-29-16
drwxr-xr-x. 2 root root 141 Mar 29 16:48 three-0
[root@backup02 logs]#
其他消费者分区
[root@backup03 kafka_2.12-2.4.1]# cd logs/
[root@backup03 logs]# ll
total 464
-rw-r--r--. 1 root root 4 Mar 29 16:31 cleaner-offset-checkpoint
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-1
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-10
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-13
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-16
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-19
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-22
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-25
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-28
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-31
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-34
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-37
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-4
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-40
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-43
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-46
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-49
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-7
-rw-r--r--. 1 root root 9685 Mar 29 15:56 controller.log
-rw-r--r--. 1 root root 578 Mar 29 13:51 controller.log.2020-03-29-13
-rw-r--r--. 1 root root 9382 Mar 29 14:03 controller.log.2020-03-29-14
-rw-r--r--. 1 root root 0 Mar 29 13:47 kafka-authorizer.log
-rw-r--r--. 1 root root 0 Mar 29 13:47 kafka-request.log
-rw-r--r--. 1 root root 17325 Mar 29 17:38 kafkaServer-gc.log.0.current
-rw-r--r--. 1 root root 100447 Mar 29 17:36 kafkaServer.out
-rw-r--r--. 1 root root 844 Mar 29 16:31 log-cleaner.log
-rw-r--r--. 1 root root 172 Mar 29 13:47 log-cleaner.log.2020-03-29-13
-rw-r--r--. 1 root root 550 Mar 29 14:03 log-cleaner.log.2020-03-29-14
-rw-r--r--. 1 root root 550 Mar 29 15:56 log-cleaner.log.2020-03-29-15
-rw-r--r--. 1 root root 4 Mar 29 17:43 log-start-offset-checkpoint
-rw-r--r--. 1 root root 88 Mar 29 15:56 meta.properties
-rw-r--r--. 1 root root 463 Mar 29 17:43 recovery-point-offset-checkpoint
-rw-r--r--. 1 root root 463 Mar 29 17:43 replication-offset-checkpoint
drwxr-xr-x. 2 root root 141 Mar 29 16:42 secend-0
drwxr-xr-x. 2 root root 141 Mar 29 16:42 secend-1
drwxr-xr-x. 2 root root 141 Mar 29 16:42 secend-2
-rw-r--r--. 1 root root 41154 Mar 29 17:36 server.log
-rw-r--r--. 1 root root 31088 Mar 29 13:57 server.log.2020-03-29-13
-rw-r--r--. 1 root root 40823 Mar 29 14:53 server.log.2020-03-29-14
-rw-r--r--. 1 root root 45717 Mar 29 15:56 server.log.2020-03-29-15
-rw-r--r--. 1 root root 27398 Mar 29 16:56 server.log.2020-03-29-16
-rw-r--r--. 1 root root 36856 Mar 29 17:34 state-change.log
-rw-r--r--. 1 root root 0 Mar 29 13:47 state-change.log.2020-03-29-13
-rw-r--r--. 1 root root 1145 Mar 29 14:02 state-change.log.2020-03-29-14
-rw-r--r--. 1 root root 25329 Mar 29 15:56 state-change.log.2020-03-29-15
-rw-r--r--. 1 root root 17415 Mar 29 16:48 state-change.log.2020-03-29-16
drwxr-xr-x. 2 root root 141 Mar 29 16:48 three-0
drwxr-xr-x. 2 root root 141 Mar 29 16:48 three-1
[root@backup03 logs]#
[root@backup01 kafka_2.12-2.4.1]# cd logs/
[root@backup01 logs]# ll
total 696
-rw-r--r--. 1 root root 4 Mar 29 16:31 cleaner-offset-checkpoint
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-11
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-14
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-17
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-2
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-20
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-23
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-26
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-29
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-32
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-35
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-38
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-41
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-44
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-47
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-5
drwxr-xr-x. 2 root root 141 Mar 29 17:34 __consumer_offsets-8
-rw-r--r--. 1 root root 22485 Mar 29 17:40 controller.log
-rw-r--r--. 1 root root 10857 Mar 29 13:51 controller.log.2020-03-29-13
-rw-r--r--. 1 root root 11117 Mar 29 14:58 controller.log.2020-03-29-14
-rw-r--r--. 1 root root 21665 Mar 29 15:56 controller.log.2020-03-29-15
-rw-r--r--. 1 root root 29350 Mar 29 16:55 controller.log.2020-03-29-16
drwxr-xr-x. 2 root root 141 Mar 29 16:32 first-0
-rw-r--r--. 1 root root 0 Mar 29 13:40 kafka-authorizer.log
-rw-r--r--. 1 root root 0 Mar 29 13:40 kafka-request.log
-rw-r--r--. 1 root root 18331 Mar 29 17:42 kafkaServer-gc.log.0.current
-rw-r--r--. 1 root root 104496 Mar 29 17:35 kafkaServer.out
-rw-r--r--. 1 root root 844 Mar 29 16:31 log-cleaner.log
-rw-r--r--. 1 root root 722 Mar 29 13:51 log-cleaner.log.2020-03-29-13
-rw-r--r--. 1 root root 550 Mar 29 15:55 log-cleaner.log.2020-03-29-15
-rw-r--r--. 1 root root 4 Mar 29 17:44 log-start-offset-checkpoint
-rw-r--r--. 1 root root 88 Mar 29 15:55 meta.properties
-rw-r--r--. 1 root root 439 Mar 29 17:44 recovery-point-offset-checkpoint
-rw-r--r--. 1 root root 439 Mar 29 17:44 replication-offset-checkpoint
drwxr-xr-x. 2 root root 141 Mar 29 16:42 secend-0
drwxr-xr-x. 2 root root 141 Mar 29 16:42 secend-1
drwxr-xr-x. 2 root root 141 Mar 29 16:42 secend-2
-rw-r--r--. 1 root root 40958 Mar 29 17:35 server.log
-rw-r--r--. 1 root root 71236 Mar 29 13:51 server.log.2020-03-29-13
-rw-r--r--. 1 root root 942 Mar 29 14:51 server.log.2020-03-29-14
-rw-r--r--. 1 root root 47315 Mar 29 15:56 server.log.2020-03-29-15
-rw-r--r--. 1 root root 31355 Mar 29 16:55 server.log.2020-03-29-16
-rw-r--r--. 1 root root 116986 Mar 29 17:34 state-change.log
-rw-r--r--. 1 root root 1374 Mar 29 13:47 state-change.log.2020-03-29-13
-rw-r--r--. 1 root root 1145 Mar 29 14:03 state-change.log.2020-03-29-14
-rw-r--r--. 1 root root 42656 Mar 29 15:56 state-change.log.2020-03-29-15
-rw-r--r--. 1 root root 72145 Mar 29 16:48 state-change.log.2020-03-29-16
drwxr-xr-x. 2 root root 141 Mar 29 16:48 three-1
我们可以分析出 集群消费者分区几乎都是轮询的消费,说明分区就是一个负载均衡的作用
这个数据默认保存168小时 保留7天 7天自动清理
7)修改分区数
bin/kafka-topics.sh --zookeeper backup01:2181 --alter --topic first --partitions 6
Kafka 命令行操作相关推荐
- 【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 命令行操作大全
kafka 命令行操作大全 一.集群相关常用命令 二.topic相关常用命令 2.1 脚本&参数简介 2.2 举例 三.生产者命令行常用操作 3.1 脚本&参数简介 3.2 举例发送消 ...
- 简单的kafka命令行操作
目录 一.主题topic命令行操作 1.查看操作主题的命令参数 2.连接kafka地址,创建名为kaf的主题,指定分区和副本数量 3.查看所有主题的名称 4.查看主题的详细信息 5.修改主题(修改分区 ...
- 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命令行操作,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 ...
最新文章
- 2022-2028年中国喹烯酮行业市场研究及前瞻分析报告
- Google Apps – Framework, Phonesky, GmsCore w/ AOSP Build.
- JQuery.validate.js 表单验证
- 将Java类作为子进程运行
- java setpriority_Java TaskEntity.setPriority方法代碼示例
- c语言 傲娇的十六进制,语言拟人向:来自Python、JAVA、C语言的“傲娇”自我介绍...
- Gson格式转换Integer变为Double类型问题解决
- kafka0.8消费者实例 1
- mysql建立唯一索引升序_MySQL数据库SQL优化技巧六之唯一索引
- FreeMarker源码分析(八)
- 二十四节气-秋分 | 文案、海报
- form表单提交方式
- 算法分析与设计实验报告——二分搜索算法的实现
- 余弦s=Acos(wt+φ)
- [蓝牙] 1、蓝牙核心技术了解(蓝牙协议、架构、硬件和软件笔记)
- [Oracle 11g r2(11.2.0.4.0)]集群守护进程CSS资源管理
- WPF输入框双向绑定Decimal类等数据无法输入小数点
- 在matlab中使用spm8,spm8处理流程.doc
- 【Vue系列】vuex详解,一篇彻底搞懂vuex
- MapReduce操作实例
热门文章
- 没有bug队——加贝——Python 练习实例 33,34
- 没有bug队——加贝——Python 练习实例 9,10
- java json u0026_特殊字符的json序列化
- oracle将千万行查询优化到一秒内,oracle下一条SQL语句的优化过程(比较详细)
- 接口可以继承抽象类吗_Python接口类的多继承以及抽象类的单继承
- linux根目录cat退出,Linux展示cat帮助信息并退出
- python记录日志_记录python日志
- 如何对一个变量数据进行正则判定_生存分析数据中的BuckleyJamesMultipleRegression Model...
- android下拉弹性gif,android-pulltorefresh 下拉加载中使用gif动图
- python 日记 day4。