kafka從2012年11月加入Apache,轉(zhuǎn)眼已經(jīng)過去了十個(gè)年頭。0.8版本,引入了副本機(jī)制,棄用了舊版Scala客戶端,誕生了消息格式v00.10版本,消息格式升至v1...
IP屬地:北京
kafka從2012年11月加入Apache,轉(zhuǎn)眼已經(jīng)過去了十個(gè)年頭。0.8版本,引入了副本機(jī)制,棄用了舊版Scala客戶端,誕生了消息格式v00.10版本,消息格式升至v1...
前言 序言 再高大上的框架,也需要扎實(shí)的基礎(chǔ)才能玩轉(zhuǎn),高頻面試問題更是基礎(chǔ)中的高頻實(shí)戰(zhàn)要點(diǎn)。 適合閱讀人群 Java 學(xué)習(xí)者和愛好者,有一定工作經(jīng)驗(yàn)的技術(shù)人,準(zhǔn)面試官等。 閱...
寫在前面 當(dāng)在10億數(shù)據(jù)進(jìn)行不到30次比較就能查找到目標(biāo)時(shí),不禁感嘆編程之魅力!人類之偉大呀! —— 學(xué)紅黑樹有感。 終于,在學(xué)習(xí)了幾天的紅黑樹相關(guān)的知識(shí)后,我想把我所學(xué)所想...
DataStream編寫的程序通常在以下情況保存狀態(tài): Windows在觸發(fā)計(jì)算之前,收集數(shù)據(jù)或聚合 Transformation functions可能使用key/valu...
新舊版本對(duì)比 早在flink1.10以前的版本,有三種時(shí)間語義: processing time,即當(dāng)前集群的處理時(shí)間 event time,即消息中附帶的消息產(chǎn)生時(shí)間 in...