02.Kafka常用命令

Leefs 2021-08-14 PM 1564℃ 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://lilinchao.com/archives/1387.html

上一篇【转载】01.初识Kafka

下一篇 CentOS7.X安装Scala2.12.10教程

02.Kafka常用命令

评论已关闭

栏目分类

标签云

友情链接申请

02.Kafka常用命令

评论已关闭

 栏目分类

标签云

友情链接申请

栏目分类

标签云

友情链接申请