转：http://blog.csdn.net/m13321169565/article/details/8081358在Activemq以前的版本中，broker会把待发送的消息保存在内存中。这种方式的缺陷是当消费者消费的速度赶不上生产者的速度时，会在broker的内存中积攒大量的消息，当达到一个限...
分类：
其他好文 时间：
2015-11-21 23:59:30
阅读次数：
389
RabbitMQ、ActiveMQ和ZeroMQ都是极好的消息中间件，但是我们在项目中该选择哪个更适合呢？很多开发者面临这个烦恼。下面我会对这三个消息中间件做一个比较，看了后你们就心中有数了。RabbitMQ是AMQP协议领先的一个实现，它实现了代理(Broker)架构，意味着消息在发送到客户端之前...
分类：
其他好文 时间：
2015-11-18 00:39:19
阅读次数：
153
采用pull模型，消息的实时性有保证吗？ Metamorphosis在消费端采用pull的模型，consumer主动去broker拉取数据，而不是类似大多数MQ那样由broker主动push数据给消费者。可能很多人担心采用pull模型后，会不会消息的...
分类：
Web程序 时间：
2015-11-10 21:17:41
阅读次数：
682
介绍 Meta相比于kafka的一个重要特性就是消息高可用方案的实现，我们称之为HA方案。消息在发送到broker之后立即写入磁盘才返回客户端告诉消息生产者消息发送成功，通过unflushThreshold和unflushInterval两个参数...
分类：
Web程序 时间：
2015-11-09 21:06:28
阅读次数：
560
原文链接：Kafka0.8.2.1删除topic逻辑前提条件： 在启动broker时候开启删除topic的开关，即在server.properties中添加：delete.topic.enable=true命令：bin/kafka-topics.sh --zookeeper zk_host:port...
分类：
其他好文 时间：
2015-11-09 20:52:22
阅读次数：
5517
startup 在onControllerFailover中被调用， /** * Invoked on successful controller election. First registers a broker change listener since that triggers all *...
分类：
系统相关 时间：
2015-11-05 15:13:17
阅读次数：
312
分布式模式之Broker模式 问题来源： 创建一个游戏系统，其将运行在互联网的环境中。客户端通过WWW服务或特定的客户端软件连接到游戏服务器，随着流量的增加，系统不断的膨胀，最终后台数据、业务逻辑被分布式的部...
分类：
其他好文 时间：
2015-10-29 11:33:01
阅读次数：
217
在kafka中，我们能创建多种类型的集群，一般如下：单节点——单个broker集群单节点——多broker集群多结点——多broker集群kafka集群中主要有五个组件：Topic：主题主要用于用一个名字标识生产者往kafka发送了什么类型的消息，作为消息归类的标识唯一键。在kafka中，主题被分区...
分类：
其他好文 时间：
2015-10-28 19:11:12
阅读次数：
167
在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的查...
