李林超博客
首页
归档
留言
友链
动态
关于
归档
留言
友链
动态
关于
首页
大数据
正文
02.Kafka常用命令
Leefs
2021-08-14 PM
1055℃
0条
# 02.Kafka常用命令 ### 一、Broker #### 1.1 启动Kafka ``` bin/kafka-server-start.sh --daemon config/server.properties ``` + **-–daemon:**以守护进程的方式启动 #### 1.2 查询进程 ``` jps -l ``` #### 1.3 停止Kafka ``` bin/kafka-server-stop.sh config/server.properties ``` ### 二、Topic #### 2.1 创建Topic ``` bin/kafka-topics.sh --zookeeper localhost:2181 --create --topic frist --partitions 2 --replication-factor 2 ``` + **--create:** 指定创建topic动作 + **--topic:**指定新建topic的名称 + **--zookeeper:** 指定kafka连接zk的连接url + **--partitions:**指定当前创建的kafka分区数量,默认为1个 + **--replication-factor:**指定每个分区的复制因子个数,默认1个 #### 2.2 查看Topic列表 ``` bin/kafka-topics.sh --zookeeper localhost:2181 --list ``` 查询出Kafka中所有Topic名称列表 #### 2.3 查看指定Topic描述信息 ``` bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topic frist ``` + **--describe:** 指定是展示详细信息命令 **输出结果** ``` Topic:frist PartitionCount:2 ReplicationFactor:2 Configs: Topic: frist Partition: 0 Leader: 1 Replicas: 1,0 Isr: 1,0 Topic: frist Partition: 1 Leader: 2 Replicas: 2,1 Isr: 2,1 ``` ##### **分析** **第一行** + **Topic:**Topic名称 + **PartitionCount:**分区数量 + **ReplicationFactor:**副本数量 **第二行往后** + **Topic:**Topic名称 + **Partition:**分区编号 + **Leader:**分区的leader broker编号 + **Replicas:**副本存放的broker编号 + **Isr:**同步broker编号 #### 2.4 修改分片数量 ``` bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic frist --partitions 10 ``` + **--alter:**修改分片数量 **注意:分片数量只能增加不能减小,减小会报错** #### 2.5 删除指定Topic 删除之前需修改如下配置,否则删除命令不生效 修改server.properties文件中的配置`delete.topic.enable=true` ``` bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic frist ``` + **--delete:**删除Topic **说明:**如果该topic还在有数据交换,那么查看topic list的时候,会显示该topic为标记删除。直到没有客户端使用该topic,才会真正的被删除。 ### 三、生产和消费消息 #### 3.1 生产消息 ``` bin/kafka-console-producer.sh --broker-list localhost:9092 --topic frist ``` #### 3.2 消费消息 ``` bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic frist # 从第一条数据开始消费 bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic frist --from-beginning ```
标签:
Kafka
非特殊说明,本博所有文章均为博主原创。
如若转载,请注明出处:
https://www.lilinchao.com/archives/1387.html
上一篇
【转载】01.初识Kafka
下一篇
CentOS7.X安装Scala2.12.10教程
取消回复
评论啦~
提交评论
栏目分类
随笔
2
Java
326
大数据
229
工具
31
其它
25
GO
47
标签云
VUE
DataWarehouse
Jquery
Hbase
JavaScript
Nacos
Linux
Filter
nginx
排序
Redis
锁
高并发
Eclipse
Java
Kafka
Stream流
稀疏数组
Spring
gorm
Hadoop
Docker
SpringCloudAlibaba
容器深入研究
线程池
Java编程思想
Jenkins
ajax
散列
随笔
友情链接
申请
范明明
庄严博客
Mx
陶小桃Blog
虫洞