Loading [MathJax]/jax/output/CommonHTML/config.js
前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
社区首页 >专栏 >Kafka命令行操作

Kafka命令行操作

作者头像
编程那点事
发布于 2023-02-25 08:04:25
发布于 2023-02-25 08:04:25
24100
代码可运行
举报
文章被收录于专栏:java编程那点事java编程那点事
运行总次数:0
代码可运行

1)查看当前集群中已存在的主题topic

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
bin/kafka-topics.sh --zookeeper hd09:2181 --list

2)创建topic

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
bin/kafka-topics.sh --zookeeper hd09-01:2181 --create --replication-facto r 3 --partitions 1 --topic guan

--zookeeper 连接zk集群 --create 创建 --replication-factor 副本 --partitions 分区 --topic 主题名

3)删除主题

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
bin/kafka-topics.sh --zookeeper hd09-01:2181 --delete --topic guan 

4)发送消息 生产者启动:

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
bin/kafka-console-producer.sh --broker-list hd09-01:9092 --topic guan

消费者启动:

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
 bin/kafka-console-consumer.sh --bootstrap-server hd09-01:9092 --topic guan --from-beginning

5)查看主题详细信息

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
bin/kafka-topics.sh --zookeeper hd09-01:2181 --describe --topic guan
本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2019-03-01,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
暂无评论
推荐阅读
编辑精选文章
换一批
快速入门Kafka系列(5)——Kafka的命令行操作
作为快速入门Kafka系列的第五篇博客,本篇为大家带来的是Kafka的命令行操作~
大数据梦想家
2021/01/27
7010
快速入门Kafka系列(5)——Kafka的命令行操作
kafka安装与测试
Producer即生产者,向Kafka集群发送消息,在发送消息之前,会对消息进行分类,即Topic, Topic即主题,通过对消息指定主题可以将消息分类,消费者可以只关注自己需要的Topic中的消息 Consumer即消费者,消费者通过与kafka集群建立长连接的方式,不断地从集群中拉取消息,然后可以对这些消息进行处理。
瑾诺学长
2018/09/21
1.7K0
Kafka快速入门(命令行操作)
Kafka 命令行操作 Kafka基础架构 主题命令行操作 1)查看操作主题命令参数 bin/kafka-topics.sh -参数 -描述 –bootstrap-server <String: server toconnect to> 连接的 Kafka Broker 主机名称和端口号。 –topic <String: topic> 操作的 topic 名称。 –create 创建主题。 –delete 删除主题。 –alter 修改主题。 –list 查看所有主题。 –describe 查看主题详细
鱼找水需要时间
2023/02/16
1.5K0
Kafka快速入门(命令行操作)
kafka 命令行工具常用命令行操作
查看consumer group列表有新、旧两种命令,分别查看新版(信息保存在broker中)consumer列表和老版(信息保存在zookeeper中)consumer列表,因而需要区分指定bootstrap–server和zookeeper参数:
大鹅
2021/06/16
5.5K0
Kafka学习笔记之Kafka命令行操作topic+producer+consumer详解
# 启动kafka服务,三台主机分别输入此指令: kafka-server-start.sh $KAFKA_HOME/config/server.properties & //以后台的方式启动 nohup kafka-server-start.sh $KAFKA_HOME/config/server.properties & //查看topic名 kafka-topics.sh --list --zookeeper hadoop-001:2181 //创建topic名 kafka-topics.sh
Jetpropelledsnake21
2021/01/14
4620
Kafka - 3.x Kafka命令行操作
这些参数是用于操作和管理Apache Kafka主题的命令行工具参数,通常用于kafka-topics.sh工具。以下是每个参数的描述:
小小工匠
2023/10/27
8090
Kafka - 3.x Kafka命令行操作
Kafka运维命令大全
1、集群管理 前台启动broker bin/kafka-server-start.sh <path>/server.properties Ctrl + C 关闭 后台启动broker bin/kafka-server-start.sh -daemon <path>/server.properties 关闭broker bin/kafka-server-stop.sh 2、Topic管理 创建topic bin/kafka-topics.sh --create --zookeeper localhost:21
用户6070864
2019/09/17
1.1K0
Kafka运维命令大全
kafka(二)Kafka快速入门
脚本 kafka]$ bin\kafka-console-producer.sh 命令选项
用户1483438
2022/04/10
7370
Kafka快速入门系列(3) | Kafka常用脚本介绍及简单的shell操作
  至于怎样查看脚本,我们可以查看Kafka/bin目录,下图标记即为常用的脚本
不温卜火
2020/10/28
6850
Kafka快速入门系列(3) | Kafka常用脚本介绍及简单的shell操作
提效| local环境下的kafka服务
在当前微服务横行, 研发提速的大环境下, 除了单测对单个方法的逻辑做验证外, 在本机环境能正常运行, 减少三方环境的依赖也是提效的一个重要环节.
一个架构师
2022/06/27
2900
kafuka学习之路(一)kafuka安装和简单使用
发布者:全栈程序员栈长,转载请注明出处:https://javaforall.cn/131623.html原文链接:https://javaforall.cn
全栈程序员站长
2022/07/01
1.4K0
kafka_2.11-2.0.0_常用操作
  表示order-group消费组有3个消费者,消费topic order的信息。
踏歌行
2020/10/15
8190
kafka_2.11-2.0.0_常用操作
Kafka安装启动入门教程
本文讲如何安装启动kafka,并进行测试,其中zookeepr是kafka自带的,本文基本按照官网文档进行安装启动的,并提出可能会出现的问题。官方文档:http://kafka.apache.org/quickstart 本文虚拟机系统:centos7,不过其他版本的Linux系统是一样的~
小明互联网技术分享社区
2022/10/31
1K2
Kafka安装启动入门教程
kafka安装使用
topic: 消息以为类别记录,Kafka将消息种子(Feed)分类, 每一类的消息称之为一个。
友儿
2022/09/13
5410
大数据环境搭建-Kafka及Zookeeper
https://zookeeper.apache.org/releases.html#download
码客说
2022/05/25
6390
Kafka 常用运维脚本
集群管理 (1)启动 broker $ bin/kafka-server-start.sh daemon <path>/server.properties (2)关闭 broker $ bin/kafka-server-stop.sh topic 管理 kafka-topics.sh 脚本 # 创建主题 $ bin/kafka-topics.sh --create --zookeeper localhost:2181 --partitions 64 --replication-factor 3 --topi
张乘辉
2020/08/27
1.4K0
kafka常用操作
kafka运维常用查询操作总结以下几点: kafka生产和消费消息测试 发送:bin/kafka-console-producer.sh --broker-list 10.46.200.165:9092 --topic contentApprove 接收:bin/kafka-console-consumer.sh --bootstrap-server 10.46.200.165:9092 --topic contentApprove --from-beginning 创建topic命令参考 .bin/kaf
钢铁知识库
2022/08/20
1840
Kafka学习(一)-------- Quickstart
截至2019年7月8日 最新版本为 2.3.0 2.12为编译的scala版本 2.3.0为kafka版本
大数据流动
2019/08/08
5760
【愚公系列】2022年03月 Docker容器 Kafka集群的搭建
Kafka的topic所有分区会分散在不同Broker上,所以该topic的5个分区会被分散到3个Broker上,其中有两个Broker得到两个分区,另一个Broker只有1个分区,如图所示:
愚公搬代码
2022/03/29
5450
【愚公系列】2022年03月 Docker容器 Kafka集群的搭建
Kafka基本操作
创建topic kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic mytopic 查看topic kafka-topics.sh --list --zookeeper localhost:2181 查看topic详情 kafka-topics.sh --describe --zookeeper localhost:2181 producer生产消息 kafka
ZHANGHAO
2018/12/11
3980
相关推荐
快速入门Kafka系列(5)——Kafka的命令行操作
更多 >
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档