在上一篇，我们从使用方式和策略上，对消息队列做了一个宏观描述。从本篇开始，我们将深入到源码内部，仔细分析Kafka到底是如何实现一个分布式消息队列。我们的分析将从Producer端开始。 从Kafka 0.8.2开始，发布了一套新的Java版的client api, KafkaProducer/Ka ...
分类：
其他好文 时间：
2016-09-25 15:58:37
阅读次数：
144
在上一篇，我们从使用方式和策略上，对消息队列做了一个宏观描述。从本篇开始，我们将深入到源码内部，仔细分析Kafka到底是如何实现一个分布式消息队列。我们的分析将从Producer端开始。从Kafka ...
分类：
Web程序 时间：
2016-09-25 09:35:54
阅读次数：
2103
Kafka架构Kafka的整体架构非常简单，是显式分布式架构，producer、broker（kafka）和consumer都可以有多个。Producer，consumer实现Kafka注册的接口，数据从producer发送到broker，broker承担一个中间缓存和分发的作用。broker分发注册到系统中的consumer。broker的作用类似于..
分类：
其他好文 时间：
2016-09-23 00:07:07
阅读次数：
268
在kafka 目录下执行生产消息命令： ./kafka-console-producer --broker-list nodexx:9092 --topic 201609 在spark bin 目录下执行 ...
分类：
其他好文 时间：
2016-09-21 15:55:27
阅读次数：
153
其中,zookeeper的地址,在kafka config/consummer.properties的目录下,要配置下 ...
分类：
其他好文 时间：
2016-09-12 06:17:00
阅读次数：
129
global 全局，全球priority 优先load 平衡 balance 负载 cluster 集群subscribe 订阅filter 过滤，滤除，滤波器producer 生产者consume 消费者payload 有效负载merge 合并reject 拒绝declare 声明。宣布guard ...
分类：
其他好文 时间：
2016-09-08 16:14:26
阅读次数：
141
调用封装好的Producer，结合Kafka监控工具KafkaOffsetMonitor的使用与分析。
分类：
其他好文 时间：
2016-08-31 09:29:28
阅读次数：
603
Kafka自定义Producer以及Partitioner，并对Producer进行一定的封装。
分类：
其他好文 时间：
2016-08-30 09:35:26
阅读次数：
925
转载自：http://www.cnblogs.com/huxi2b/p/4583249.html 供参考 本文分析的Kafka代码为kafka-0.8.2.1。另外，由于Kafka目前提供了两套Producer代码，一套是Scala版的旧版本；一套是Java版的新版本。虽然Kafka社区极力推荐大家 ...
分类：
其他好文 时间：
2016-08-26 13:35:47
阅读次数：
464
1 基本概念 rabbitmq server(broker server)：rabbitmq服务 client：包括producers和consumer message：包括payload和label exchange：producer发布message的地方 queue：messages存放和co ...
分类：
其他好文 时间：
2016-08-26 01:13:31
阅读次数：
283
