from kafka.client import KafkaClient
client = KafkaClient(“zookeeper_host”)
topic_list = client.topics...
分类：
编程语言 时间：
2015-08-04 21:16:01
阅读次数：
179
一、环境一台Centos6.5主机Mongo 3.0Kafka_2.11-0.8.2.1Storm-0.9.5Zookeeper-3.4.6java 1.7 （后因在mac上打包的jar由1.8编译没法儿运行，改为java 1.8）其余环境暂略二、运行启动启动zookeeper确认配置正确，配置相关...
分类：
数据库 时间：
2015-08-04 19:05:17
阅读次数：
756
每个kafka broker中配置文件server.properties默认必须配置的属性如下：
[java] view
plaincopy
broker.id=0
num.network.threads=2
num.io.threads=8
socket.send.buffer.bytes=1048576
socket....
分类：
Web程序 时间：
2015-08-04 13:41:59
阅读次数：
116
Kafka是一个分布式的、可分区的、可复制的消息系统。它提供了普通消息系统的功能，但具有自己独特的设计。这个独特的设计是什么样的呢？
首先让我们看几个基本的消息系统术语：
Kafka将消息以topic为单位进行归纳。将向Kafka topic发布消息的程序成为producers.将预订topics并消费消息的程序成为consumer.Kafka以集群的方式运行，可以由一个或多个服...
分类：
其他好文 时间：
2015-08-04 13:37:40
阅读次数：
101
Step 1: 下载Kafka
点击下载最新的版本并解压.
> tar -xzf kafka_2.9.2-0.8.1.1.tgz
> cd kafka_2.9.2-0.8.1.1
Step 2: 启动服务
Kafka用到了Zookeeper，所有首先启动Zookper，下面简单的启用一个单实例的Zookkeeper服务。可以在命令的结尾加个&符号，这样就可以启动后离开控制台。
> ...
分类：
系统相关 时间：
2015-08-04 13:35:34
阅读次数：
167
。。。最近天热的，感觉就像煎饼。。。然后别人在把妹子的时候，只有偶们这帮苦逼的程序员在那边撸代码。。。我日哦！然后今天晒的是偶早年写的一个播放器。。。看上去是不是很有感觉的样子！一番宝物，Lisa唱的 在angel beats的插曲最后在简述这个东西怎么写之前，本人男，24岁，籍贯上海，诚招女友一枚...
分类：
Web程序 时间：
2015-08-04 00:33:10
阅读次数：
175
如题，Elasticserch内存小，造成jvm的内存溢出，或者就是集群状态变为Red。网上很多都是不经过自己的操作，下面贴代码。下面是调参的方法源码的调参，就是找到文件[root@localhostbin]#pwd
/home/data/elasticsearch-1.5.2/bin
[root@localhostbin]#ls
1.jsonelasticsearch.in...
分类：
其他好文 时间：
2015-08-03 22:58:23
阅读次数：
220
RocketMQ 源码分析RocketMQ 的设计思想来自于Kafka,在具体设计时体现了自己的选择和需求，具体差别可以看RocketMQ与Kafka对比（18项差异）。接下来记录下自己阅读源码的一些探索。
RocketMQ的整体架构如下，可以看到各个组件充当的角色，Name Server 负责维护一些全局的路由信息：当前有哪些broker，每个Topic在哪个broker上等; Broker具体处...
分类：
其他好文 时间：
2015-08-01 23:37:44
阅读次数：
754
高吞吐的分布式消息系统相当于一个大缓存架构伪分布式的安装tar -xzf kafka_2.10-0.8.1.1.tgz启动ZK bin/zookeeper-server-start.sh config/zookeeper.properties启动服务 bin/kafka-server-start.s...
分类：
其他好文 时间：
2015-07-31 23:29:13
阅读次数：
202
