macos 一些kafka命令整理

1 Kafka bin目录路径

/usr/local/Cellar/kafka/bin，里面包含Kafka的各种操作命令：

kafka-server-start，服务启动命令kafka-server-stop，服务停止命令kafka-topics，主题操作命令kafka-console-producer，生产消息命令kafka-console-consumer，消费消息

2 Kafka的配置文件路径

/usr/local/etc/kafkazookeeper.properties，zookeeper的配置文件server.properties，Kafka服务的配置文件

3 修改Kafka的配置文件

vim /usr/local/etc/kafka/server.properties增加：listeners=PLAINTEXT://localhost:9092

4 一些kafka命令

进入bin目录：

1 新建topic主题 cstest

kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic cstest

出现：Created topic test. 表明建立topic成功

2 查看kafka topic列表

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

创建成功的话会在此显示刚刚的topic名称：

3 启动生产者客户端生产消息

kafka-console-producer --topic cstest --broker-list localhost:9092

出现>符号，表示启动成功，可以开始生产消息

插入一条消息"hello?"

4 启动消费者客户端消费消息

# 显示当前信息
kafka-console-consumer --bootstrap-server localhost:9092 -topic cstest# 显示所有信息
kafka-console-consumer --bootstrap-server localhost:9092 -topic cstest --from-beginning

显示当前信息：

显示所有信息：

5 删除kafka topic主题

kafka-topics  --delete --zookeeper localhost:2181 --topic  cstest

6 查看topic信息

kafka-topics --describe --zookeeper localhost:2181 --topic cstest

7 查看consumer group列表

kafka-consumer-groups --bootstrap-server localhost:9092 --list

8 查看特定consumer group 详情

使用–group与–describe参数

bin/kafka-consumer-groups=  --bootstrap-server localhost:9292 --group YOUR_GROUP_ID --describe

9 查看指定topic上每个partition的offset

只是用于查看指定topic上相应分区的消息数，并不是consumer消费的偏移量

kafka-run-class kafka.tools.GetOffsetShell --broker-list localhost:9092 --topic cstest

macos 一些kafka命令整理相关推荐

为什么 Linux 和 macOS 不需要碎片整理
为什么这么设计(Why's THE Design)是一系列关于计算机领域中程序设计决策的文章,我们在这个系列的每一篇文章中都会提出一个具体的问题并从不同的角度讨论这种设计的优缺点.对具体实现造成的影响 ...
lldb 常用命令整理
lldb 常用命令整理 -- 飘云推荐一个不用下载就可以玩app游戏的网站,http://h5-apps.com,更新速度绝对最快,真爽啊 lldb命令支持缩写,自己慢慢研究吧优雅人生飘云原创整理 ...
kafka命令行操作大全
最近利用flink使用一个流式SQL处理平台,利用kafka, mysql, hive等组件比较多,命令行突然间需要操作一次记不住命令很麻烦,索性直接整理成笔记. 在 0.9.0.0 之后的 Kafk ...
Redis 命令整理
Redis 命令整理一.从大而全的方向看,完整的命令查看文档地址: http://doc.redisfans.com/ 二.Redis 键(key) 常用案例三.Redis 字符串(Stri ...
linux的网络命令整理更新中
linux的网络命令整理更新中 1.安装包: net-tools 主要命令: netstat , ifconfig , route , iptunnel iproute 主要命令: ss , ip ...
最详细的SQL注入相关的命令整理
最详细的SQL注入相关的命令整理 QUOTE: 1. 用^转义字符来写ASP(一句话***)文件的方法: ? http://192.168.1.5/display.asp?keyno=18 ...
python常用命令汇总-python数据分析之pandas常用命令整理
原标题:python数据分析之pandas常用命令整理 pandas 是基于NumPy 的一种工具,该工具是为了解决数据分析任务而创建的.Pandas 纳入了大量库和一些标准的数据模型 ,提供了高效地 ...
Emacs基础命令整理 - Unplugged - 博客频道 - CSDN.NET
Emacs基础命令整理 - Unplugged - 博客频道 - CSDN.NET Emacs基础命令整理分类: Unix /GNU Linux 2005-06-03 23:45 1649人阅读评 ...
工作中常用的kafka命令
Kafka常用命令以下是kafka常用命令行总结: 1.查看topic的详细信息 /data/bin/kafka/bin//kafka-topics.sh --zookeeper 172.16.2 ...

macos 一些kafka命令整理

1 Kafka bin目录路径

2 Kafka的配置文件路径

3 修改Kafka的配置文件

4 一些kafka命令

1 新建topic主题 cstest

2 查看kafka topic列表

3 启动生产者客户端生产消息

4 启动消费者客户端消费消息

5 删除kafka topic主题

6 查看topic信息

7 查看consumer group列表

8 查看特定consumer group 详情

9 查看指定topic上每个partition的offset

macos 一些kafka命令整理相关推荐

最新文章

热门文章

macos 一些kafka命令整理

1 Kafka bin目录路径

2 Kafka的配置文件路径

3 修改Kafka的配置文件

4 一些kafka命令

1 新建topic主题 cstest

2 查看kafka topic列表

3 启动生产者客户端 生产消息

4 启动消费者客户端消费消息

5 删除kafka topic主题

6 查看topic信息

7 查看consumer group列表

8 查看特定consumer group 详情

9 查看指定topic上每个partition的offset

macos 一些kafka命令整理相关推荐

最新文章

热门文章

3 启动生产者客户端生产消息