通常伦连，我們寫一段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í)也可以看出來(lái)猖任，無(wú)非就是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如下面簡(jiǎn)單的代碼： 從上面的API可以看到其中一個(gè)非常重要的對(duì)象： Kafka...