对于kafka的consumer接口,提供两种版本, high-level 一种high-level版本,比较简单不用关心offset, 会自动的读zookeeper中该Consumer group的last offset 参考,https://cwiki.apache.org/confluence...
分类:
其他好文 时间:
2014-06-28 22:39:15
阅读次数:
1224
参考, https://cwiki.apache.org/confluence/display/KAFKA/System+Tools https://cwiki.apache.org/confluence/display/KAFKA/Replication+tools http://kafka.ap...
分类:
其他好文 时间:
2014-06-28 22:01:55
阅读次数:
637
调用wait()和notify()方法的前提是,线程调用这两个方法时,拥有当前对象的monitor,即锁。所以,这两种方法的调用必须放在synchronized方法或synchronized块中。
分类:
编程语言 时间:
2014-06-18 15:19:10
阅读次数:
312
操作系统: debian 7.4(linux 3.2.54)硬件: 一个无线鼠标、一个有线鼠标从淘宝上花了15块钱买了个无线鼠标,很好奇它的驱动程序是如何执行的。首先执行下面命令来捕获uevent事件:sudo udevadm monitor然后插入和移除再插入无线鼠标的nano接收器(为了完整的查...
分类:
系统相关 时间:
2014-06-18 14:54:40
阅读次数:
478
1、新建一个Windows窗体应用程序,例如项目名为monitor,功能略。新建的时候不要忘了创建解决方案。2、在monitor解决方案上“右击”—— “添加”——“新建项目”,选择“其他类型项目”——“安装和部署”——“安装项目”,并命名为“Setupmonitor”,确定后显示如下图所示3、添加...
简介Apache Kafka是分布式发布-订阅消息系统。它最初由LinkedIn公司开发,之后成为Apache项目的一部分。Kafka是一种快速、可扩展的、设计内在就是分布式的,分区的和可复制的提交日志服务。Apache Kafka与传统消息系统相比,有以下不同:它被设计为一个分布式系统,易于向外扩...
分类:
其他好文 时间:
2014-06-17 20:04:58
阅读次数:
201
本文主要介绍一个轻量级的文件监控方式,对文件的Create & Change & Delete,都有一个对应的Event方法来进行处理。对于核心的File Monitor Class,我们继承一个监听适配器类FileAlterationListenerAdaptor,这样会更文件,不用再去重写每个Event方法。...
分类:
编程语言 时间:
2014-06-16 21:23:44
阅读次数:
285
var navH = $(".diy_titleedit").offset().top; //获取要定位元素距离浏览器顶部的距离 var tit_fixed = true; $(window).scroll(function(){//滚动条事件 ...
分类:
其他好文 时间:
2014-06-15 09:02:44
阅读次数:
189
JAMon简介JAMon的全名是:Java Application Monitor。它是一个小巧的,免费的,高性能的,线程安全的性能监测工具。它可以用来测定系统的性能瓶颈,也可以用来监视用户和应用程序之间的交互情况。Jamon主要是用来检测jee的应用程序。JAMon集成到项目中假设现在有一个项目名...
分类:
Web程序 时间:
2014-06-14 21:43:13
阅读次数:
436
未改偏移量之前
using (FileStream fs = new FileStream(txtFilePathRead.Text, FileMode.Open))
{
//创建一个容量4M的数组
byte[] byteData = new byte[1024 * 1024 * 4];...
分类:
其他好文 时间:
2014-06-14 14:13:27
阅读次数:
216