【http://www.infoq.com/cn/articles/apache-kafka/】分布式发布-订阅消息系统。Kafka是一种快速、可扩展的、设计内在就是分布式的，分区的和可复制的提交日志服务。Apache Kafka与传统消息系统相比，有以下不同：它被设计为一个分布式系统，易于向外扩展...
分类：
Web程序 时间：
2015-07-07 18:56:15
阅读次数：
133
先上代码
class Test
{
public static void main(String []args)
{
Queue q=new Queue();
Producer p=new Producer(q);
Consumer c=new Consumer(q);
...
分类：
编程语言 时间：
2015-07-07 14:50:12
阅读次数：
130
http://riddickbryant.iteye.com/blog/441890【发送端】session = connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE);producer.setDeliveryMode(De...
分类：
其他好文 时间：
2015-07-07 14:34:10
阅读次数：
163
1.topic注册信息/brokers/topics/[topic] :存储某个topic的partitions所有分配信息Schema:{ "version": "版本编号目前固定为数字1", "partitions": { "partitionId编号": [ 同步副本组br...
分类：
其他好文 时间：
2015-07-07 12:47:49
阅读次数：
209
1：kafka-topics.sh（如果没有返回信息，说明命令无效）创建一个top名字：gbz4，zookeeper地址：本机，两个分区，两个副本./bin/kafka-topics.sh -create --topic 'gbz4' --zookeeper '127.0.0.1' --partit...
分类：
其他好文 时间：
2015-07-07 12:25:30
阅读次数：
147
一个、整体外观Kafka我们知道。Kafka系统有三大组件：Producer、Consumer、broker 。producers 生产(produce)消息(message)并推(push)送给brokers，consumers从brokers把消息提取(pull)出来消费(consume)。二、...
分类：
其他好文 时间：
2015-07-05 09:28:08
阅读次数：
158
Pinot 是一个实时分布式的 OLAP 数据存储和分析系统。LinkedIn 使用它实现低延迟可伸缩的实时分析。Pinot 从离线数据源（包括 Hadoop 和各类文件）和在线数据源（如 Kafka）中攫取数据进行分析。Pinot 被设计是可以进行水平扩展的。...
分类：
其他好文 时间：
2015-07-03 17:35:04
阅读次数：
284
kafka集群搭建与api客户端创建，以前的消息队列（activeMQ）对于大数据吞吐率不行，但kafka很好的解决了此类问题，并且以集群的方式进行扩展，可谓相当强大...
其一：Source code: Lib/queue.pyThe queue module implements multi-producer, multi-consumer queues. It is especially useful in threaded programming when in...
分类：
编程语言 时间：
2015-07-02 09:58:07
阅读次数：
215
package com.doctor.logbackextend;import java.util.HashMap;import java.util.List;import java.util.Map;import java.util.Properties;import kafka.consumer...
分类：
Web程序 时间：
2015-07-01 20:32:42
阅读次数：
174
