Kafka操作命令

妖狐艹你老母 2023-01-21 11:25 91阅读 0赞

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

\[atguigu@hadoop102 kafka\]$ bin/kafka-topics.sh --zookeeper hadoop102:2181 \--list

2)创建 topic

\[atguigu@hadoop102 kafka\]$ bin/kafka-topics.sh --zookeeper hadoop102:2181 \--create \--replication-factor 3 --partitions 1 -- topic first

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

3)删除 topic

<table> 
 <tbody> 
  <tr> 
   <td> <p>[atguigu@hadoop102 kafka]$ bin/kafka-topics.sh --zookeeper</p> </td> 
  </tr> 
  <tr> 
   <td> <p>hadoop102:2181 <span style="color:#f33b45;">--delete</span> --topic first</p> </td> 
  </tr> 
 </tbody> 
</table>

需要 server.properties 中设置 delete.topic.enable=true 否则只是标记删除。

4)发送消息

\[atguigu@hadoop102 kafka\]$ bin/kafka-console-producer.sh --broker- list hadoop102:9092 --topic first  
>hello world  
>atguigu atguigu

5)消费消息

老版本用zookeeper，新版本用bootstrap，offset存储在本地

\[atguigu@hadoop102 kafka\]$ bin/kafka-console-consumer.sh \\ --zookeeper hadoop102:2181 --topic first

\[atguigu@hadoop102 kafka\]$ bin/kafka-console-consumer.sh \\ --bootstrap-server hadoop102:9092 --topic first

\[atguigu@hadoop102 kafka\]$ bin/kafka-console-consumer.sh \\ --bootstrap-server hadoop102:9092 --from-beginning --topic first

6)查看某个 Topic 的详情

\[atguigu@hadoop102 kafka\]$ bin/kafka-topics.sh --zookeeper hadoop102:2181 --describe --topic first

7)修改分区数

<table> 
 <tbody> 
  <tr> 
   <td> <p>[atguigu@hadoop102 kafka]$ bin/kafka-topics.sh --zookeeper</p> </td> 
  </tr> 
  <tr> 
   <td> <p>hadoop102:2181 --alter --topic first --partitions 6</p> </td> 
  </tr> 
 </tbody> 
</table>

发表评论取消回复

表情：

评论列表（有 0 条评论，91人围观）

还没有评论，来说两句吧...

相关阅读

相关 Kafka的各种相关命令操作操作

Kafka的各种相关命令操作操作 * * * 启动 * 关闭 * 查看是否启动 * 查询和删除...

ゝ一纸荒年。/ 2024年04月18日 10:33/ 0 赞/ 81 阅读

相关 Kafka：常见命令行操作

主题命令行操作 bin/kafka-topics.sh <table style="width:500px;"> <tbody> <tr> <

àì夳堔傛蜴生んèń/ 2024年03月24日 14:13/ 0 赞/ 86 阅读

相关 Kafka的命令行操作

一、topic命令下面`Windows`命令需要把`cmd`路径切换到`bin/windows`下。而`Linux`命令只需要在控制台切换到`bin`目录下即可。

缺乏、安全感/ 2024年03月23日 11:16/ 0 赞/ 50 阅读

相关 Kafka入门之命令行操作

1.创建topic [root@node01 kafka]$ bin/kafka-topics.sh --zookeeper node01:2181,node02

女爷i/ 2023年02月19日 14:28/ 0 赞/ 25 阅读

相关 Kafka操作命令

1)查看当前服务器中的所有 topic \[atguigu@hadoop102 kafka\]$ bin/kafka-topics.sh --zookeeper hadoop

妖狐艹你老母/ 2023年01月21日 11:25/ 0 赞/ 92 阅读

相关 kafka生产者、消费者消息操作命令

sender： ![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5a

ゞ浴缸里的玫瑰/ 2022年09月11日 06:21/ 0 赞/ 215 阅读

相关 Kafka总结（四）：Kafka命令操作

[Kafka总结（一）：Kafka概述][Kafka_Kafka] [Kafka总结（二）：Kafka核心组件][Kafka_Kafka 1] [Kafka总结（三）：Ka

曾经终败给现在/ 2022年05月18日 04:40/ 0 赞/ 267 阅读

相关 Kafka命令操作

本文主要介绍Kafka的shell命令：查看当前服务器所有的topic <table> <tbody> <tr> <td><pre><span>1

古城微笑少年丶/ 2022年04月25日 01:50/ 0 赞/ 242 阅读

相关 kafka常用命令操作

1、查看所有的topic /opt/cloudera/parcels/KAFKA-2.2.0-1.2.2.0.p0.68/lib/kafka/bin/kafka-topic

淩亂°似流年/ 2022年03月17日 16:42/ 0 赞/ 483 阅读

相关 Kafka入门-基础操作命令-常用命令

主题操作创建主题使用以下命令创建一个叫作 my-topic 的主题，主题包含 8 个分区，每个分区拥有两个副本。 kafka-topics.sh --

矫情吗；*/ 2021年11月22日 13:10/ 0 赞/ 365 阅读