原文：http://www.aboutyun.com/thread-9341-1-1.html 问题导读： 1.zookeeper在kafka的作用是什么？ 2.kafka中几乎不允许对消息进行“随机读写”的原因是什么？ 3.kafka集群consumer和producer状态信息是如何保存...
分类：
其他好文 时间：
2015-11-11 16:51:26
阅读次数：
308
采用pull模型，消息的实时性有保证吗？ Metamorphosis在消费端采用pull的模型，consumer主动去broker拉取数据，而不是类似大多数MQ那样由broker主动push数据给消费者。可能很多人担心采用pull模型后，会不会消息的...
分类：
Web程序 时间：
2015-11-10 21:17:41
阅读次数：
682
近期在学习队列相关的一些知识，在学习过程中发现Iterable接口中新增了两个新的方法，出于好奇，就想知道这是什么东东，干什么用的。俗话说：实践出真知，所以就有了以下反复的测试。先看下新增的这两个方法：1 default void forEach(Consumer action) {2 ...
分类：
编程语言 时间：
2015-11-03 12:00:17
阅读次数：
778
B=Business，即企业；C=Customers，即消费者，这样就好理解这些简称了；M=Medium，即媒介B2B：（Business To Business）商家对商家进行交易 如：阿里巴巴、生意宝；B2C：（Business To Consumer）商家对个人进行交易 如：京东商城、当当.....
分类：
移动开发 时间：
2015-11-02 00:07:52
阅读次数：
309
六、Message Consumer ????????一、配置消费者：每个Java的消费者都需要一个ConsumerConfig的配置实例。 ????????二、消费者分组?????? ????????????????在MetaQ里，消费者...
分类：
Web程序 时间：
2015-10-28 19:44:05
阅读次数：
2736
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
解决dubbo问题：forbid consumer By?admin?|?2015/06/09 0 Comment 线下环境经常出现类似这种异常： com.alibaba.dubbo.rpc.RpcException: Forbid consumer 10.0.53.69 access service com.kuaidadi.op.api.pa...
分类：
其他好文 时间：
2015-10-28 10:59:38
阅读次数：
1690
kafka apis反映出kafka broker server可以提供哪些服务，broker server主要和producer，consumer，controller有交互，搞清这些api就清楚了broker server的所有行为 handleOffsetRequest 提供对offset的查...
具体可以参考：《Effective Java》PECS 原则 (producser-extends, consumer-super)G[+A]类似一个生产者，提供数据。（大部分情况下称G为容器类型）G[-A] 是一个消费者，主要用来消费数据。（如上的 Equiv[-A] （其实就是个A => Boo...
分类：
其他好文 时间：
2015-10-24 23:14:05
阅读次数：
242
问题导读：1.zookeeper在kafka的作用是什么？2.kafka中几乎不允许对消息进行“随机读写”的原因是什么？3.kafka集群consumer和producer状态信息是如何保存的？4.partitions设计的目的的根本原因是什么？一、入门 1、简介 Kafka is a dist.....
分类：
其他好文 时间：
2015-10-22 12:15:25
阅读次数：
163
