通常，我們寫一段flink stream api代碼類型如下： 熟悉flink的人都知道，最后這行代碼env.execute(topics);實(shí)際上是把我們的代碼提交到環(huán)境上...
發(fā)簡(jiǎn)信
IP屬地：福建
-
01-Flink代碼生成StreamGraph
-
本博客所有內(nèi)容均適用知識(shí)共享-署名-相同方式共享（CC-BY-SA）4.0協(xié)議。
-
寫的不錯(cuò)，加油，我看好你
3.Kafka源碼深入解析之元數(shù)據(jù)結(jié)構(gòu)
前面我們講到，在KafkaProducer初始化時(shí)，初始化了一個(gè)非常核心的組件Metadata 這個(gè)組件前面也詳細(xì)說(shuō)明過(guò)，是去broker上 拉取一次集群的元數(shù)據(jù)過(guò)來(lái)的，我...
-
加油，寫的很好
7.Kafka源碼深入解析之發(fā)送消息01
上一章節(jié)我們重點(diǎn)分析了獲取消息的分區(qū)號(hào)，這樣我們才知道消息到底要發(fā)送到哪個(gè)broker上，對(duì)吧，同時(shí)我們看到后面把消息封裝到一個(gè)TopicPartition對(duì)象 接下來(lái)，我們...
-
8.Kafka源碼深入解析之發(fā)送消息02上一章節(jié)我們?cè)趏rg.apache.kafka.clients.producer.internals.RecordAccumulator#append最開(kāi)始簡(jiǎn)單分析了一下發(fā)送...
-
7.Kafka源碼深入解析之發(fā)送消息01
上一章節(jié)我們重點(diǎn)分析了獲取消息的分區(qū)號(hào)，這樣我們才知道消息到底要發(fā)送到哪個(gè)broker上，對(duì)吧，同時(shí)我們看到后面把消息封裝到一個(gè)TopicPartition對(duì)象 接下來(lái)，我們...
-
6.Kafka源碼深入解析之分區(qū)器
上一章節(jié)我們?cè)敿?xì) 分析了Kafka在發(fā)送消息的時(shí)候，是如何拉取元數(shù)據(jù)的，正如我們?cè)创a里doSend()里waitOnMetadata介紹的： 接下是key,value的序列化...
-
metadata.max.age.ms //缺省300000，即10分鐘1次
五分鐘一次吧，
寫的不錯(cuò)，贊，快達(dá)到我水平的十分之一了，加油??Kafka源碼深度解析－序列2 －Producer －Metadata的數(shù)據(jù)結(jié)構(gòu)與讀取、更新策略
在上一篇，我們從使用方式和策略上，對(duì)消息隊(duì)列做了一個(gè)宏觀描述。從本篇開(kāi)始，我們將深入到源碼內(nèi)部，仔細(xì)分析Kafka到底是如何實(shí)現(xiàn)一個(gè)分布式消息隊(duì)列。我們的分析將從Produc...
-
Kafka源碼深度解析－序列2 －Producer －Metadata的數(shù)據(jù)結(jié)構(gòu)與讀取、更新策略
在上一篇，我們從使用方式和策略上，對(duì)消息隊(duì)列做了一個(gè)宏觀描述。從本篇開(kāi)始，我們將深入到源碼內(nèi)部，仔細(xì)分析Kafka到底是如何實(shí)現(xiàn)一個(gè)分布式消息隊(duì)列。我們的分析將從Produc...
-
5.Kafka源碼深入解析之拉取元數(shù)據(jù)02
上一節(jié)我們?cè)敿?xì)解析了生產(chǎn)端在發(fā)消息的dosend()里，首先是拉取元數(shù)據(jù)信息，在拉取過(guò)程中，先喚醒了sender線程，接著主線程進(jìn)入等待狀態(tài)，直到sender線程拉取元數(shù)據(jù)成...
-
4.Kafka源碼深入解析之拉取元數(shù)據(jù)01
上一節(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è)诘诙鹿?jié)KafkaProduce...
-
3.Kafka源碼深入解析之元數(shù)據(jù)結(jié)構(gòu)
前面我們講到，在KafkaProducer初始化時(shí)，初始化了一個(gè)非常核心的組件Metadata 這個(gè)組件前面也詳細(xì)說(shuō)明過(guò)，是去broker上 拉取一次集群的元數(shù)據(jù)過(guò)來(lái)的，我...
-
2.Kafka源碼深入解析之生產(chǎn)端初始化
上一節(jié)我們講到了在KafkaProducer初始化的時(shí)候，初始化了三個(gè)組件： 分區(qū)器Partitioner 序列化器Serializer 攔截器Interceptor 接下來(lái)...
-
1.Kafka源碼深入解析之生產(chǎn)端初始化
當(dāng)我們學(xué)習(xí)Kafka時(shí)，通常寫kafka producer api如下面簡(jiǎn)單的代碼： 從上面的API可以看到其中一個(gè)非常重要的對(duì)象： KafkaProducer produ...
-
Centos7下安裝kudu簡(jiǎn)介 kudu官網(wǎng)https://kudu.apache.org/ 準(zhǔn)備 直接通過(guò)yum install是找不到kudu的源的，在官網(wǎng)安裝的頁(yè)面詳細(xì)介紹了怎么在各種系統(tǒng)下安裝...
