学习进度：服务端框架进度名称描述状态ThinkPHPphp MVC框架掌握yiiphp MVC框架spring mvcjava MVC框架common.js服务端：定义应用程序使用的APInode.js服务端：commonjs的实现kafka分布式消息系统，异步处理redisKV存储hadoopHD...
分类：
其他好文 时间：
2015-06-02 16:44:00
阅读次数：
95
十四、AbstractFetcherManager.scala该scala定义了两个case类和一个抽象类。两个case类很简单：1. BrokerAndFectherId：封装了一个broker和一个fetcher的数据结构2. BrokerAndInitialOffset：封装了broker和初...
分类：
其他好文 时间：
2015-06-02 10:51:12
阅读次数：
135
pom.xml 4.0.0 kafka_demo2 kafka_demo2 0.0.1-SNAPSHOT org.apache.kafka kafka_2.10 0.8.2.1 生产消息的代码:import java.util.Proper...
分类：
其他好文 时间：
2015-05-31 10:52:06
阅读次数：
141
原文:http://mp.weixin.qq.com/s?__biz=MjM5NzAyNTE0Ng==&mid=205526269&idx=1&sn=6300502dad3e41a36f9bde8e0ba2284d&key=c468684b929d2be22eb8e183b6f92c75565b81...
分类：
数据库 时间：
2015-05-28 21:11:11
阅读次数：
769
使用Kafka的同学都知道，我们每次创建Kafka主题（Topic）的时候可以指定分区数和副本数等信息，如果将这些属性配置到server.properties文件中，以后调用Java API生成的主题将使用默认值，先改变需要使用命令bin/kafka-topics.sh --zookeeper lo...
分类：
编程语言 时间：
2015-05-28 17:45:49
阅读次数：
458
kafka创建topic时出现如下异常:Errorwhileexecutingtopiccommandorg.apache.zookeeper.KeeperException$NoNodeException:KeeperErrorCode=NoNodefor/brokers/idsorg.I0Itec.zkclient.exception.ZkNoNodeException:org.apache.zookeeper.KeeperException$NoNodeException:Keeper..
分类：
其他好文 时间：
2015-05-28 14:26:09
阅读次数：
2040
这个是Kafka server的核心包，里面的类也很多，我们还是一个一个分析一、BrokerStates.scala定义了目前一个kafka broker的7中状态 ——1. NotRunning：未运行2. Starting：启动中3. RecoveringFromUncleanShutdown：...
分类：
其他好文 时间：
2015-05-28 09:26:17
阅读次数：
4713
一.zookeeper下载与安装1）下载adeMacBook-Pro:zookeeper_soft apple$ wget http://mirrors.cnnic.cn/apache/zookeeper/zookeeper-3.4.6/zookeeper-3.4.6.tar.gz2）解压tar z...
分类：
系统相关 时间：
2015-05-27 20:50:37
阅读次数：
365
摘要 Kafka在0.8以前的版本中，并不提供High Availablity机制，一旦一个或多个Broker宕机，则宕机期间其上所有Partition都无法继续提供服务。若该Broker永远不能再恢复，亦或磁盘故障，则其上数据将丢失。而Kafka的设计目标之一即是提供数据持久化，同时对于分布式系....
分类：
其他好文 时间：
2015-05-27 15:23:04
阅读次数：
132
下载kafka正式版
http://kafka.apache.org/downloads.html
在Linux下解压tar包
tar -xzfkafka_2.9.2-0.8.1.1.tgz
修改server.properties
进入kafka根目录config/server.properties
主要修改的有3个参数如下：...
分类：
其他好文 时间：
2015-05-25 18:51:27
阅读次数：
248
