查看各个patition消息的最大位移

sh kafka-run-class.sh kafka.tools.GetOffsetShell --topic mytopic --time -1 --broker-list host1:9092,host2:9092,host3:9092

查看各个partition消息的最小位移

sh kafka-run-class.sh kafka.tools.GetOffsetShell --topic mytopic --time -2 --broker-list host1:9092,host2:9092,host3:9092

计算可消费的消息个数

a=`sh kafka-run-class.sh kafka.tools.GetOffsetShell --topic mytopic --time -1 --broker-list host1:9092,host2:9092,host3:9092|awk -F':' '{print $3}'| awk ' { SUM += $1 } END { print SUM }'`

b=`sh kafka-run-class.sh kafka.tools.GetOffsetShell --topic mytopic --time -2 --broker-list host1:9092,host2:9092,host3:9092|awk -F':' '{print $3}'| awk ' { SUM += $1 } END { print SUM }'`

echo $(($a-$b))

最新文章

1. C# WinForm 中 MessageBox的使用详解
2. Android 学习笔记之WebService实现远程调用+内部原理分析...
3. maven工程导入时解决Cannot change version of project facet Dynamic Web Module to 2.3
4. ffplay 参数说明分享
5. MySQL配置SQL Assistant提示
6. 关于Windows平台下应用程序加载DLL模块的问题.
7. Redis的安装、配置 --转载
8. win7+SQL2008无法打开物理文件 操作系统错误 5:拒绝访问 SQL Sever
9. iOS 9适配技巧（更新版）
10. 关于Python网络爬虫实战笔记①
11. PB数据库相关
12. Fedora 20 Gnome安装及配置记录
13. Struts2 stracture
14. 编译OpenGL代码时发生 Inconsistency detected by ld.so: dl-version.c: 224: _dl_check_map_versions: Assertion `needed != ((void *)0)' failed! 错误的解决方案
15. IOC：AutoFac使用demo
16. for循环问题
17. web3.js
18. jquery配合.NET实现点击指定绑定数据并且能够一键下载
19. 移动端使用fastclick时，模拟原生浏览器对象
20. Centos创建ftp服务器

热门文章

1. gcc和g++理解
2. java~通过springloaded实现热部署
3. 苹果电脑清理软件CleanMyMac X好用吗？
4. 教你调节Boom 3D的3D音效强度，让音乐更带感
5. 用OCR文字识别工具来审阅和处理PDF内容
6. H5系列之contenteditable
7. 这些Stream流的常用方法你得记住，步骤简单不麻烦！
8. Java集合【1】--俯瞰java集合分类
9. 【问题记录】— web页面调用本地程序
10. python之汉诺塔