Kafka操作命令

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

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

相关阅读

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

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

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

相关 1、Kafka2.2.1操作命令

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

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

相关 Python 操作 Kafka --- kafka-python

kafka-python：[https://github.com/dpkp/kafka-python][https_github.com_dpkp_kafka-python]

本是古典何须时尚/ 2022年10月10日 11:18/ 0 赞/ 328 阅读

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

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

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

相关 Kafka（四）：Java操作Kafka

一、准备工作 > 提前说明：如果你运行出问题，请检查Kafka的版本与Maven kafka client的版本是否与我文中的一致。环境：Kafka版本为 kafka

た入场券/ 2022年05月27日 08:49/ 0 赞/ 190 阅读

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

相关 kafka基本操作命令收集----持续更新中

查看帮助信息 bin/kafka-topics.sh --help 创建Topic bin/kafka-topics.sh --create --

深碍√TFBOYSˉ_/ 2022年04月16日 02:24/ 0 赞/ 250 阅读

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

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

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

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