原文地址:http://www.aboutyun.com/thread-9938-1-1.html问题导读1.Kafka提供了Producer类作为java producer的api,此类有几种发送方式?2.总结调用producer.send方法包含哪些流程?3.Producer难以理解的在什么地方...
分类:
Web程序 时间:
2014-12-24 13:08:58
阅读次数:
189
IntroductionApache Kafkais a distributed publish-subscribe messaging system. It was originally developed at LinkedIn Corporation and later on became a...
分类:
Web程序 时间:
2014-12-23 20:47:23
阅读次数:
262
[This article was originally written by Yves Trudeau.]http://java.dzone.com/articles/exploring-message-brokersMessage brokersare not regularly covered...
分类:
其他好文 时间:
2014-12-22 14:19:03
阅读次数:
230
深入理解Magento作者:Alan Storm 翻译:Hailong Zhang第六章 – 高级Magento模型我们讲过Magento有两种模型,简单模型和EAV(Entity Attribute Value)模型。上一章我们讲过所有的Magento模型都是继承自Mage_Core_Model....
分类:
其他好文 时间:
2014-12-22 12:44:30
阅读次数:
283
There are two kinds of nodes on a Storm cluster: the master node and the worker nodes.有两种节点,主节点和worker节点主节点,Nimbus:Nimbus is responsible for distribut...
分类:
其他好文 时间:
2014-12-22 11:04:29
阅读次数:
140
1.背景最近因为工作需要,调研了追求高吞吐的轻量级消息系统Kafka,打算替换掉线上运行的ActiveMQ,主要是因为明年的预算日流量有十亿,而ActiveMQ的分布式实现的很奇怪,所以希望找一个适合分布式的消息系统。以下是内容是调研过程中总结的一些知识和经验,欢迎拍砖。2.基础知识2.1.什么是消...
分类:
其他好文 时间:
2014-12-21 20:36:57
阅读次数:
290
kafka单机部署kafka是一种高吞吐量的分布式发布订阅消息系统,kafka是linkedin用于日志处理的分布式消息队列,linkedin的日志数据容量大,但对可靠性要求不高,其日志数据主要包括用户行为环境配置:
CentOSrelease6.3(Final)
jdk版本:jdk-6u31-linux-x64-rpm.bin
zookeeper版..
分类:
其他好文 时间:
2014-12-19 19:23:50
阅读次数:
225
Why use netty as transport instead of zeromq in Storm...
分类:
Web程序 时间:
2014-12-18 22:19:05
阅读次数:
249
spark 、storm提供了向Cassandra直接存储数据的功能。但是国内对Cassandra本身的源码研究不深,参考资料较少。我将最近研究的源码分析贴上,和大家一起共享。...
分类:
其他好文 时间:
2014-12-18 18:49:24
阅读次数:
226
1 Topology构成 和同样是计算框架的Mapreduce相比,Mapreduce集群上运行的是Job,而Storm集群上运行的是Topology。但是Job在运行结束之后会自行结束,Topology却只能被手动的kill掉,否则会一直运行下去。 Storm集群中有两种节点,一种是控制节点(Ni...
分类:
其他好文 时间:
2014-12-18 11:56:38
阅读次数:
180