Kafka操作命令

妖狐艹你老母 2023-01-21 11:25 77阅读 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 条评论，77人围观）

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

相关阅读

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

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

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

相关 Kafka：常见命令行操作

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

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

相关 Kafka操作命令

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

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

相关 zk和kafka的常用操作命令

在准备好相应的配置之后，可以直接通过zkServer.sh 这个脚本进行服务的相关操作 1. 启动ZK服务: sh bin/zkServer.sh start 2. 查看

妖狐艹你老母/ 2022年11月14日 00:47/ 0 赞/ 212 阅读

相关 1、Kafka2.2.1操作命令

1 没有关注的小伙伴可以在微信搜索框中搜索微信公众号： 3分钟秒懂大数据，然后点击关注，回复 kafka 即可免费领取 kafka\_2.12-2.2.1.tgz 软件安

梦里梦外;/ 2022年10月18日 11:29/ 0 赞/ 172 阅读

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

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

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

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

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

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

相关 Kafka命令操作

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

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

相关 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 赞/ 463 阅读

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

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

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