專注基礎(chǔ)服務(wù)中間件,底層技術(shù)架構(gòu),RPC框架/SOA/彈性計(jì)算。目前在螞蟻金服中間件團(tuán)隊(duì)。
IP屬地:上海
本節(jié)重點(diǎn)討論 Kafka 的消息拉起流程。 @TOC 1、KafkaConsumer poll 詳解 消息拉起主要入口為:KafkaConsumer#poll方法,其聲明如下...
溫馨提示:本文基于 Kafka 2.2.1 版本。 上文 《源碼分析 Kafka 消息發(fā)送流程》 已經(jīng)詳細(xì)介紹了 KafkaProducer send 方法的流程,該方法只是...