寫在開頭 好久沒有去寫博客了,最近一年發(fā)生了太多事情,感覺自己需要好好沉淀和消化這些,也更加需要去思考未來的路該如何去走,趁著這段時間比較空閑坟冲,寫幾篇關于spring的知識點...
寫在開頭 好久沒有去寫博客了,最近一年發(fā)生了太多事情,感覺自己需要好好沉淀和消化這些,也更加需要去思考未來的路該如何去走,趁著這段時間比較空閑坟冲,寫幾篇關于spring的知識點...
上一章節(jié)我們重點分析了獲取消息的分區(qū)號脐彩,這樣我們才知道消息到底要發(fā)送到哪個broker上惋鹅,對吧王暗,同時我們看到后面把消息封裝到一個TopicPartition對象 接下來悔据,我們...
上一節(jié)我們詳細解析了生產(chǎn)端在發(fā)消息的dosend()里,首先是拉取元數(shù)據(jù)信息俗壹,在拉取過程中科汗,先喚醒了sender線程,接著主線程進入等待狀態(tài)绷雏,直到sender線程拉取元數(shù)據(jù)成...
上一節(jié)我們詳細解析了生產(chǎn)端拉取元數(shù)據(jù)的數(shù)據(jù)結構头滔,其實也可以看出來,無非就是topic ,partition,node之間的對應關系涎显,同時我們在第二章節(jié)KafkaProduce...
前面我們講到坤检,在KafkaProducer初始化時,初始化了一個非常核心的組件Metadata 這個組件前面也詳細說明過棺禾,是去broker上 拉取一次集群的元數(shù)據(jù)過來的缀蹄,我...
當我們學習Kafka時,通常寫kafka producer api如下面簡單的代碼: 從上面的API可以看到其中一個非常重要的對象: KafkaProducer produ...
上一節(jié)我們講到了在KafkaProducer初始化的時候膘婶,初始化了三個組件: 分區(qū)器Partitioner 序列化器Serializer 攔截器Interceptor 接下來...
上一章節(jié)我們詳細 分析了Kafka在發(fā)送消息的時候缺前,是如何拉取元數(shù)據(jù)的,正如我們源碼里doSend()里waitOnMetadata介紹的: 接下是key,value的序列化...
下載 到 https://github.com/protocolbuffers/protobuf/releases 選擇下載最新的protoc-3.6.1-osx-x86_6...