我在网上搜了很多资料 说是zookeeper的问题，修改更改server.properties下的host.name,zookeeper.connect的localhost 为ip地址? 怎么也不管用 后来就单独建了一个项目，发现没有问题。结论是jar包冲突，逐个删除...
分类：
其他好文 时间：
2015-04-10 18:13:04
阅读次数：
179
Kafka可以配置使用JMX进行运行状态的监控，既可以通过JDK自带Jconsole来观察结果，也可以通过Java API的方式来.
关于监控指标的描述，可以参考：http://kafka.apache.org/documentation.html#monitoring
开启JMX端口
修改bin/kafka-server-start.sh，添加JMX_PORT参数，添加后样...
分类：
其他好文 时间：
2015-04-10 18:07:24
阅读次数：
363
1、下载kafka? https://www.apache.org/dyn/closer.cgi?path=/kafka/0.8.2.0/kafka_2.10-0.8.2.0.tgz ? ?tar -xzf kafka_2.10-0.8.2.0.tgz ? cd kafka_2.10-0.8.2.0 2、启动服务 ? ? 启动zookeeper服务 启动...
分类：
其他好文 时间：
2015-04-09 17:56:44
阅读次数：
101
Kafka+Storm+HDFS整合实践本文导读：1 前言2 Kafka安装配置3 Storm安装配置4 整合Kafka+Storm5 整合Storm+HDFS6 整合Kafka+Storm+HDFS7 参考链接
分类：
其他好文 时间：
2015-04-08 16:21:02
阅读次数：
127
这个包主要是与Kafka度量相关的。一、KafkaTimer.scala对代码块的运行进行计时。仅提供一个方法: timer——在运行传入函数f的同时为期计时二、KafkaMetricsConfig.scala指定reporter类，以逗号分隔的reporter类，比如kafka.metrics.K...
分类：
其他好文 时间：
2015-04-08 10:38:22
阅读次数：
138
kafka.network包主要为kafka提供网络服务，通常不包含具体的逻辑，都是一些最基本的网络服务组件。其中比较重要的是Receive、Send和Handler。Receive和Send封装了底层的入站(inbound)和出站(outbound)字节传输请求，而Handler在此二者间做了一个...
分类：
Web程序 时间：
2015-04-08 09:07:36
阅读次数：
211
分布式消息系统：KafkaKafka是分布式发布-订阅消息系统。它最初由LinkedIn公司开发，之后成为Apache项目的一部分。Kafka是一个分布式的，可划分的，冗余备份的持久性的日志服务。它主要用于处理活跃的流式数据。在大数据系统中，常常会碰到一个问题，整个大数据是由各个子系统组成，数据需要...
分类：
其他好文 时间：
2015-04-03 12:57:02
阅读次数：
199
初一看common包的代码吓了一跳，这么多scala文件！后面仔细一看大部分都是Kafka自定义的Exception类，简直可以改称为kafka.exceptions包了。由于那些异常类的名称通常都定义得很直观，笔者就不在一一赘述了。现在我们说说common包中其他的代码。一、AppInfo.sca...
分类：
其他好文 时间：
2015-04-01 13:14:20
阅读次数：
119
Kafka utils包最后一篇~~~十五、ShutdownableThread.scala可关闭的线程抽象类！ 继承自Thread同时还接收一个boolean变量isInterruptible表明是否允许中断。既然是可关闭的，因此一定不是守护线程，而是一个用户线程(不会阻塞JVM关闭)。提供的方法...
分类：
其他好文 时间：
2015-03-31 19:25:41
阅读次数：
222
最近开研究kafka，下面分享一下kafka的设计原理。kafka的设计初衷是希望作为一个统一的信息收集平台,能够实时的收集反馈信息,并需要能够支撑较大的数据量,且具备良好的容错能力.1、持久性kafka使用文件存储消息,这就直接决定kafka在性能上严重依赖文件系统的本身特性.且无论任..
分类：
其他好文 时间：
2015-03-31 13:03:36
阅读次数：
224
