zfb050 | 发布于 2017-05-16 17:22:58 | 阅读量 94 | kafka client NIO
发布于 2017-05-16 17:22:58 | kafka client NIO
> 从Kafka 0.8.2开始,发布了一套新的Java版的client api,KafkaProducer/KafkaConsumer,替代之前的scala版的api。 ## REF [Kafka: Producer (0.10.0.0)](http://www.infocool.net/kb/OtherCloud/201611/212499.html) [Kafka源码分析 Produ
继续阅读
zfb050 | 发布于 2017-05-16 17:22:58 | 阅读量 51 | kafka client
发布于 2017-05-16 17:22:58 | kafka client
探究`org.apache.kafka.clients`中Metadata的数据结构、更新及获取原理 [ref](http://www.infocool.net/kb/Other/201609/193278.html) **Metadata**是为producer及consumer服务的,在producer和consumer创建的时候都会创metadata: ``` this.metada
继续阅读
zfb050 | 发布于 2017-05-16 17:22:58 | 阅读量 304 | kafka client
发布于 2017-05-16 17:22:58 | kafka client
# REF * [KafkaConsumer API doc](https://kafka.apache.org/0100/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html) * [Kafka 之 Group 状态变化分析及 Rebalance 过程](https://wangzzu.github.io/2017/01/16
继续阅读
zfb050 | 发布于 2017-05-16 17:22:58 | 阅读量 57 | kafka client
发布于 2017-05-16 17:22:58 | kafka client
为了方便用户感知发送的情况,kafka producer中提供了`callback`机制,springkafka中实现了`ProducerListener` ### 遇到的问题 近期生产环境上由于版本BUG问题导致一段时间内某台broker出现假死的异常状态,在这异常期间内发送到该broker上的消息都失败了。在各个系统中我们实现了一个ProducerListener用于将发送失败的消息写入
继续阅读
zfb050 | 发布于 2017-05-16 17:22:58 | 阅读量 56 | kafka client
发布于 2017-05-16 17:22:58 | kafka client
> [早期整理的spring kafka Listener的实现](http://note.youdao.com/noteshare?id=7c6966ee22cebfb83c8f332ec1bc7714) [TOC] #**两个与分区分配有关的回调函数** springKafka在创建了Consumer后会订阅topic,这时会传入一个`RebalenceListener`,这个list
继续阅读