zfb050 | 发布于 2017-05-16 17:22:54 | 阅读量 40 | kafka NIO
发布于 2017-05-16 17:22:54 | kafka NIO
>kafka的socket server是基于java NIO,使用`Reactor`模式开发的。socketserver主要用于处理kafka server对外提交网络请求的操作,用于检查连接数,把请求添加到请求的队列中,对KafkaApis提供操作支持. 其线程模型为: - 一个Acceptor线程接受/处理所有的新连接 - N个Processor线程,每个Processor都有自己
继续阅读
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
继续阅读