一、下载官网的压缩包~二、解压并启动Zookeepertar zxvf kafka_2.11-0.8.2.2.tgz//在kafka根目录下执行./bin/zookeeper-server-start.sh config/zookeeper.properties &三、启动kafkabin/kafk...
分类：
其他好文 时间：
2015-11-01 16:27:17
阅读次数：
242
一.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-10-30 10:49:07
阅读次数：
259
package?org.phoenix.cases.kafka;import?java.io.File;
import?java.io.FileNotFoundException;
import?java.io.FileReader;
import?java.io.IOException;
import?java.io.RandomAccessFile;
import?jav...
分类：
移动开发 时间：
2015-10-29 16:39:59
阅读次数：
191
转发自玖疯的博客 http://www.cnblogs.com/lxf20061900/p/3866252.html Spark Streaming是一个新的实时计算的利器，而且还在快速的发展。它将输入流切分成一个个的DStream转换为RDD，从而可以使用Spark来处理。它直接支持多种数据源.....
分类：
Web程序 时间：
2015-10-29 13:11:47
阅读次数：
328
在kafka中，我们能创建多种类型的集群，一般如下：单节点——单个broker集群单节点——多broker集群多结点——多broker集群kafka集群中主要有五个组件：Topic：主题主要用于用一个名字标识生产者往kafka发送了什么类型的消息，作为消息归类的标识唯一键。在kafka中，主题被分区...
分类：
其他好文 时间：
2015-10-28 19:11:12
阅读次数：
167
Java?客户端连接Kafka报如下错误 bin/kafka-console-consumer.sh?--zookeeper?255.255.255.255:2181?--topic?eventbustopic
[2015-06-02?16:23:04,375]?WARN?Fetching?topic?metadata?with?correlati...
分类：
编程语言 时间：
2015-10-28 12:56:08
阅读次数：
740
AvroSource简介：监听Avro端口并从外部的Avro客户端接收事件流，多个flumeagent可以通过Avro形成一个组织。PropertyName Default Descriptionchannels – type – 需要配置为Avrobind – 需要监听的主机名或ip地址port – 监听的端口threads – 工作的最大线程数selector.type..
分类：
Web程序 时间：
2015-10-28 01:47:31
阅读次数：
239
在broker的配置中，auto.leader.rebalance.enable (false) 那么这个leader是如何进行rebalance的？ 首先在controller启动的时候会打开一个scheduler， if (config.autoLeaderRebalanceEnable) { ...
分类：
Web程序 时间：
2015-10-27 13:07:08
阅读次数：
292
kafka apis反映出kafka broker server可以提供哪些服务，broker server主要和producer，consumer，controller有交互，搞清这些api就清楚了broker server的所有行为 handleOffsetRequest 提供对offset的查...
