二、kafka基本操作和管理

2024-05-09 14:13:28

列出所有主题

kafka-topics.bat --zookeeper localhost:2181 --list

列出所有主题的详细信息

kafka-topics.bat --zookeeper localhost:2181 --describe

创建主题主题名 my-topic，1 副本，8 分区

kafka-topics.bat --zookeeper localhost:2181 --create --topic my-topic --replication-factor 1 --partitions 8

增加分区，注意：分区无法被删除

kafka-topics.bat --zookeeper localhost:2181 --alter --topic my-topic --partitions 16

创建生产者（控制台）

kafka-console-producer.bat --broker-list localhost:9092 --topic my-topic

创建消费者（控制台）

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic my-topic --from-beginning

列出消费者群组（仅 Linux）

kafka-topics.sh --new-consumer --bootstrap-server localhost:9092 --list

列出消费者群组详细信息（仅 Linux）

kafka-topics.sh --new-consumer --bootstrap-server localhost:9092 --describe --group 群组名

二、kafka基本操作和管理相关推荐

kafka集群管理工具kafka-manager
一.kafka-manager简介 kafka-manager是目前最受欢迎的kafka集群管理工具,最早由雅虎开源,用户可以在Web界面执行一些简单的集群管理操作.具体支持以下内容: 管理多个集群 ...
动手学Docker-第二弹-基本操作
动手学Docker-第二弹-基本操作 Docker三大基本概念镜像Image 容器Container 仓库Repository Docker Registry Docker Registry 公开服 ...
AD域建设管理（二）| python3+ldap3管理AD域实践（批量创建OU、用户、改密码、更新OU与用户）
AD域建设管理(二)| python3+ldap3管理AD域实践(批量创建OU.用户.改密码.更新OU与用户) 1.使用前提 1.1.关于程序运行环境 1.2.关于AD域的准备和配置 2.问题和解决方 ...
C语言内存管理内幕(二）----半自动内存管理策略
2019独角兽企业重金招聘Python工程师标准>>> C语言内存管理内幕(二)----半自动内存管理策略转载于:https://my.oschina.net/hengcai001 ...
Linux学习之CentOS(二十三)--Linux软件管理之源代码以及RPM软件包管理
在Linux系统下,对于软件包的管理有多种机制,有源代码方式.RPM软件包管理方式以及YUM软件管理方式,本篇随笔将详细讲解CentOS下源代码形式安装软件以及RPM软件包管理机制一.源代码形式首 ...
Xen Server二安装xc及管理xen主机
Xen Server二安装xc及管理xen主机上篇我们已经安装好xen主机,这篇我们将在win机器上安装xen center也就是xen的管理工具,用来管理xen主机,相当于微软的scvmm或者vm ...
mysql 基础篇(二) 账号、权限管理
mysql 基础篇(二) 账号.权限管理.备份与还原建立账号密码: Grant all on test.* to "cj"@"localhost" ident ...
Windows内存管理学习笔记（二）—— 物理内存的管理
Windows内存管理学习笔记(二)-- 物理内存的管理物理内存实验一:理解MmNumberOfPhysicalPages MmPfnDatabase _MMPFN 物理页状态六个链表实验二: ...
IT项目管理总结：第十二章项目采购管理
第十二章项目采购管理项目采购管理的重要性 –外包的好处: A)获得技能和技术 B)降低固定和周期性成本 C)使客户组织集中在自己的核心业务上 D)提供灵活性 E)提高可追责性 –项目采购管理(Pr ...

最新文章

热门文章