通常蛉顽，我們寫一段flink stream api代碼類型如下： 熟悉flink的人都知道，最后這行代碼env.execute(topics);實(shí)...

上一章節(jié)我們重點(diǎn)分析了獲取消息的分區(qū)號(hào)，這樣我們才知道消息到底要發(fā)送到哪個(gè)broker上，對(duì)吧，同時(shí)我們看到后面把消息封裝到一個(gè)TopicPar...

上一章節(jié)我們?cè)敿?xì) 分析了Kafka在發(fā)送消息的時(shí)候，是如何拉取元數(shù)據(jù)的恋谭，正如我們?cè)创a里doSend()里waitOnMetadata介紹的： 接...

上一節(jié)我們?cè)敿?xì)解析了生產(chǎn)端在發(fā)消息的dosend()里场斑，首先是拉取元數(shù)據(jù)信息漓踢，在拉取過程中，先喚醒了sender線程漏隐，接著主線程進(jìn)入等待狀態(tài)喧半，直...

上一節(jié)我們?cè)敿?xì)解析了生產(chǎn)端拉取元數(shù)據(jù)的數(shù)據(jù)結(jié)構(gòu)，其實(shí)也可以看出來青责，無非就是topic ,partition,node之間的對(duì)應(yīng)關(guān)系挺据，同時(shí)我們?cè)诘?..

前面我們講到，在KafkaProducer初始化時(shí)脖隶，初始化了一個(gè)非常核心的組件Metadata 這個(gè)組件前面也詳細(xì)說明過扁耐，是去broker上 ...

上一節(jié)我們講到了在KafkaProducer初始化的時(shí)候，初始化了三個(gè)組件： 分區(qū)器Partitioner 序列化器Serializer 攔截器...

當(dāng)我們學(xué)習(xí)Kafka時(shí)产阱，通常寫kafka producer api如下面簡單的代碼： 從上面的API可以看到其中一個(gè)非常重要的對(duì)象： Kafka...