一个、整体外观Kafka我们知道。Kafka系统有三大组件：Producer、Consumer、broker 。producers 生产(produce)消息(message)并推(push)送给brokers，consumers从brokers把消息提取(pull)出来消费(consume)。二、...
分类：
其他好文 时间：
2015-07-05 09:28:08
阅读次数：
158
其一：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 producer_customer;public class ProducerCustomer1 {public static int limit = 10;public static int have = 0;public static int start = 0;Task[] t...
分类：
编程语言 时间：
2015-06-29 23:48:13
阅读次数：
190
一、概述模拟生产者消费者问题二、代码1.Consumer.java2.Producer.java3.SyncStack.java4.Test.java1.Consumer.javapackage ProducerConsumer;public class Consumer implements Ru...
分类：
编程语言 时间：
2015-06-29 13:00:48
阅读次数：
117
1、Single Threaded Execution Pattern(单线程运行模式)2、Immutable Pattern(一成不变的模式)3、Guarded Suspension Pattern(国防暂停模式)4、Balking Pattern(止步模式，阻行模式)5、Producer-Con...
分类：
编程语言 时间：
2015-06-22 19:17:58
阅读次数：
148
本文分析的Kafka代码为kafka-0.8.2.1。另外，由于Kafka目前提供了两套Producer代码，一套是Scala版的旧版本；一套是Java版的新版本。虽然Kafka社区极力推荐大家使用Java版本的producer，但目前很多已有的程序还是调用了Scala版的API。今天我们就分析一下...
分类：
其他好文 时间：
2015-06-17 15:20:57
阅读次数：
145
Kafka为broker,producer和consumer提供了很多的配置参数。 了解并理解这些配置参数对于我们使用kafka是非常重要的。本文列出了一些重要的配置参数。官方的文档Configuration比较老了，很多参数有所变动， 有些名字也有所改变。我在整理的过程中根据0.8.2的代码也做了...
分类：
其他好文 时间：
2015-06-13 20:09:26
阅读次数：
113
多线程： 生产与消费1.生产者Producer生产produce产品，并将产品放到库存inventory里；同时消费者Consumer从库存inventory里消费consume产品。2.库存inventory的总量（最大库存量100）是有限的。如果库存inventory满了，生产者不能在库存inv...
分类：
编程语言 时间：
2015-06-13 20:05:47
阅读次数：
179
apache kafka区QQ群:1622725571.依赖包 org.apache.kafka kafka_2.10 0.8.1 2.producer程序开发样例2.1 producer參数说明#指定kafka节点列表。用于获取metadata，不必所有...
分类：
编程语言 时间：
2015-06-13 11:13:23
阅读次数：
171
该包下只有一个文件：ClientUtils.scala。它是一个object，里面封装了各种client(包括producer，consumer或admin)可能会用到的方法：1. fetchTopicMetadata(producer版本)： producer client会调用该方法来发送一个T...
分类：
其他好文 时间：
2015-06-09 16:42:08
阅读次数：
211
