ConsumerConfig.scala 储存Consumer的配置
按照我的理解，0.10的Kafka没有专门的SimpleConsumer，仍然是沿用0.8版本的。
1.从poll开始
消费的规则如下：
一个partition只能被同一个ConsumersGroup的一个线程所消费.
线程数小于partition数，某些线程会消费多个partition.
线程数等于partition数，一个线程正好消费一个线程.
当添加消费者线程时，会触发rebalance，partition的分配发送变化.
同一个partition的offset保证消费有序，不同的partition消费不保证顺序.
Consumers编程的用法：
private final KafkaConsumer<Long, String> consumer; // 与Kafka进行通信的consumer... consumer = new KafkaConsumer<Long, String>(props); consumer.subscribe(Collections.singletonList(this.topic)); ConsumerRecords<Long, String> records = consumer.poll(512); ...
consumer，是一个纯粹的单线程程序，后面所讲的所有机制(包括coordinator，rebalance, heartbeat等)，都是在这个单线程的poll函数里面完成的。也因此，在consumer的代码内部，没有锁的出现。
延伸阅读
- ssh框架 2016-09-30
- 阿里移动安全 [无线安全]玩转无线电——不安全的蓝牙锁 2017-07-26
- 消息队列NetMQ 原理分析4-Socket、Session、Option和Pipe 2024-03-26
- Selective Search for Object Recognition 论文笔记【图片目标分割】 2017-07-26
- 词向量-LRWE模型-更好地识别反义词同义词 2017-07-26
- 从栈不平衡问题 理解 calling convention 2017-07-26
- php imagemagick 处理 图片剪切、压缩、合并、插入文本、背景色透明 2017-07-26
- Swift实现JSON转Model - HandyJSON使用讲解 2017-07-26
- 阿里移动安全 Android端恶意锁屏勒索应用分析 2017-07-26
- 集合结合数据结构来看看(二) 2017-07-26
学习是年轻人改变自己的最好方式