Java IO/NIO JVM原理与配置、调优 Socket 网络套接字技术 Java Collection java Reflection 多线程与并发编程 设计模式 Collection深入 流式计算原理及应用场景 Storm Kafka Redis 实战案例 离线计算原理及应用场景 Hadoo ...
分类：
其他好文 时间：
2016-04-11 22:12:45
阅读次数：
242
12.3 KafkaController PartitionStateMachine
它实现了topic的分区状态切换功能，Partition存在的状态如下：
状态名
状态存在的时间
有效的前置状态
NonExistentPartition
1.partition重来没有被创建
2.partition创建之后被删除
...
分类：
其他好文 时间：
2016-04-11 12:23:09
阅读次数：
343
12.6 KafkaController内部的listener
KafkaControler（leader）通过在zk的不同目录建立各种listener来达到对topic的管理和维护，其在zk的目录结构和对应的listener如下：
12.6.1 brokerChangeListener
/**
* This is the zookeeper listener that tri...
分类：
其他好文 时间：
2016-04-11 12:22:37
阅读次数：
337
培训大数据架构开发！ 从零基础到高级，一对一培训！[技术QQ：2937765541] 课程体系： 获取视频资料和培训解答技术支持地址 课程展示(大数据技术很广，一直在线为你培训解答！)： 获取视频资料和培训解答技术支持地址 ...
分类：
Web程序 时间：
2016-04-11 01:47:24
阅读次数：
155
培训大数据架构开发！ 从零基础到高级，一对一培训！[技术QQ：2937765541] 课程体系： 获取视频资料和培训解答技术支持地址 课程展示(大数据技术很广，一直在线为你培训解答！)： 获取视频资料和培训解答技术支持地址 ...
分类：
Web程序 时间：
2016-04-11 01:32:22
阅读次数：
260
kafka分布式搭建(192.168.230.129)master(192.168.230.130)slave1(192.168.230.131)salve2在master、slave1、slave2三台主机上配置kafaka分布式集群
准备工作：在三台机器上配置好zookeeper1、解压kafka压缩文件到指定目录下[root@master software]# tar -zxf kafka_2...
分类：
其他好文 时间：
2016-04-10 14:37:34
阅读次数：
210
【时间】： 2016/4/8 17:30 【问题】： kafka执行Consumer实例的时候，发生了一下错误。 kafka配置文件server.properties如下： zookeeper配置文件zoo.cfg内容如下： consumer的实现代码如下： 其中静态类的定义如下： 共通方法的实现如 ...
分类：
编程语言 时间：
2016-04-08 19:40:07
阅读次数：
218
1.从Kafka官网下载最新的Kafka，目前最新版本为0.9.0.12.下载完毕后，上传到Linux服务器，并解压tar-xzfkafka_2.11-0.9.0.1.tgz3.修改Zookeeper服务器配置，并启动cdkafka_2.11-0.9.0.1
viconfig/zookeeper.properties
#修改ZooKeeper的数据目录
dataDir=/opt/favccxx/db/zook..
分类：
系统相关 时间：
2016-04-08 15:31:19
阅读次数：
190
Kafka是一种高吞吐量的分布式发布订阅消息系统，它可以处理消费者规模的网站中的所有动作流数据。也可以把它当作是分布式提交日志的发布-订阅消息，事实上Kafka官网上也是这么说明的。关于Kafk你必须知道的几个关键术语topics：Kafka接收的各种各样的消息producers：发送消息到..
分类：
其他好文 时间：
2016-04-07 19:00:18
阅读次数：
1557
