设为首页 加入收藏

TOP

kafa学习笔记二--kafka Tool
2019-05-02 02:29:31 】 浏览:68
Tags:kafa 学习 笔记 --kafka Tool

本章主要学习kafka里一些管理脚本,通过脚本学习我们可以更方便的学习和使用kafka。

kafka-server-start脚本 启动kafka server
kafka-server-stop脚本 关闭kafka server
kafka-topics脚本 负责kafka中Topic相关操作。如:创建Topic,查询Topic详细信息,添加分区并完成新增的副本等等
kafka-preferred-replica-election脚本 触发指定的分区进行“优先副本”的选举,这样可以让分区Leader副本在集群中分布更均匀
kafka-reassign-partition脚本 主要有三个功能:1.生成副本迁移方案;2.触发副本迁移操作,即将迁移方案写入到ZooKeeper中,从而触发PartitionReassignedListener处理;3.检测指定分区的副本迁移是否完成
kafka-console-producer脚本 控制台版本的生产者,我们可以在控制台输入消息的key-value,通过该脚本发送给服务端
kafka-console-consumer脚本

控制台版本的消费者,我们可以指定订阅的Topic,使用脚本从服务端拉取消息并输出到控制台

kafka-consumer-groups脚本 主要有两个功能:1.查询当前所有Consumer Group;2.获取指定Consumer Group的详细信息
DumpLogSegments

可由kafka-run-class脚本运行,主要负责解析输出指定的日志文件和索引文件中的内容,还可以实现索引文件的验证。

kafka-producer-perf-test脚本 测试生产者的各项性能指标
kafka-consumer-perf-test脚本 测试消费者的各项性能指标
kafka-mirrir-maker脚本 实现了数据在多个集群的同步,可用于kafka集群的镜像制作

】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
上一篇如何从ActiveMQ平滑迁移到Kafka? 下一篇Kafka配置SSL认证

最新文章

热门文章

Hot 文章

Python

C 语言

C++基础

大数据基础

linux编程基础

C/C++面试题目