Kafka：常见命令行操作

àì夳堔傛蜴生んèń 2024-03-24 14:13 100阅读 0赞

### 主题命令行操作 ###

bin/kafka-topics.sh

<table style="width:500px;"> 
 <tbody> 
  <tr> 
   <td style="width:253px;">参数</td> 
   <td style="width:246px;">描述</td> 
  </tr> 
  <tr> 
   <td style="width:253px;">--bootstrap-server</td> 
   <td style="width:246px;">连接的 Kafka Broker 主机名称和端口号。</td> 
  </tr> 
  <tr> 
   <td style="width:253px;">--topic</td> 
   <td style="width:246px;">操作的 topic 名称。</td> 
  </tr> 
  <tr> 
   <td style="width:253px;">--create</td> 
   <td style="width:246px;">创建主题。</td> 
  </tr> 
  <tr> 
   <td style="width:253px;">--delete</td> 
   <td style="width:246px;">删除主题。</td> 
  </tr> 
  <tr> 
   <td style="width:253px;">--alter</td> 
   <td style="width:246px;">修改主题。</td> 
  </tr> 
  <tr> 
   <td style="width:253px;">--list</td> 
   <td style="width:246px;">查看所有主题。</td> 
  </tr> 
  <tr> 
   <td style="width:253px;">--describe</td> 
   <td style="width:246px;">查看主题详细描述。</td> 
  </tr> 
  <tr> 
   <td style="width:253px;">--partitions</td> 
   <td style="width:246px;">设置分区数。</td> 
  </tr> 
  <tr> 
   <td style="width:253px;">--replication-factor</td> 
   <td style="width:246px;">设置分区副本。</td> 
  </tr> 
  <tr> 
   <td style="width:253px;">--config</td> 
   <td style="width:246px;">更新系统默认的配置。</td> 
  </tr> 
 </tbody> 
</table>

**案例**

**查看当前服务器中的所有 topic**

bin/kafka-topics.sh --bootstrap-server 192.168.25.129:9092 --list

**创建 first topic**

bin/kafka-topics.sh --bootstrap-server 192.168.25.129:9092 --create --partitions 1 --replication-factor 3 --topic first

选项说明： --topic 定义 topic 名 --replication-factor 定义副本数 --partitions 定义分区数

**查看 first 主题的详情**

bin/kafka-topics.sh --bootstrap-server 192.168.25.129:9092 --describe --topic first

**修改分区数**（注意：分区数只能增加，不能减少）

bin/kafka-topics.sh --bootstrap-server 192.168.25.129:9092 --alter --topic first --partitions 3

**删除 topic**

bin/kafka-topics.sh --bootstrap-server 192.168.25.129:9092 --delete --topic first

### 生产者命令行操作 ###

bin/kafka-console-producer.sh

**案例**

**发送消息**

bin/kafka-console-producer.sh --bootstrap-server 192.168.25.129:9092 --topic first
    >hello world
    >atguigu atguigu

### 消费者命令行操作 ###

bin/kafka-console-consumer.sh

<table style="width:500px;"> 
 <tbody> 
  <tr> 
   <td>参数</td> 
   <td>描述</td> 
  </tr> 
  <tr> 
   <td>--bootstrap-server</td> 
   <td>连接的 Kafka Broker 主机名称和端口号。</td> 
  </tr> 
  <tr> 
   <td>--topic</td> 
   <td>操作的 topic 名称。</td> 
  </tr> 
  <tr> 
   <td>--from-beginning</td> 
   <td>从头开始消费。</td> 
  </tr> 
  <tr> 
   <td>--group</td> 
   <td>指定消费者组名称。</td> 
  </tr> 
 </tbody> 
</table>

**案例**

**消费 first 主题中的数据**

bin/kafka-console-consumer.sh --bootstrap-server 192.168.25.129:9092 --topic first

**把主题中所有的数据都读取出来**（包括历史数据）

bin/kafka-console-consumer.sh --bootstrap-server 192.168.25.129:9092 --from-beginning --topic first