一、下载官网的压缩包~二、解压并启动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
一、前言 最近在学习WPF，学习WPF首先上的是微软的MSDN，然后再搜索了一下网络有关WPF的学习资料。为了温故而知新把学习过程记录下来，以备后查。这篇主要讲WPF的开发基础，介绍了如何使用VisualStudio2013创建一个WPF应用程序。首先说一下学习WPF的基础知识：1)要会一门.NET...
在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
在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的查...
1.Kafka入门经典教程： http://www.aboutyun.com/thread-12882-1-1.html2.分布式服务框架 Zookeeper -- 管理分布式环境中的数据 https://www.ibm.com/developerworks/cn/opensource/os-cn-...
分类：
其他好文 时间：
2015-10-25 11:59:26
阅读次数：
141
