準(zhǔn)備材料 1. docker環(huán)境,我使用的是19.03.1 2. 安裝docker-compose curl -L https://get.daocloud.io/docke...
準(zhǔn)備材料 1. docker環(huán)境,我使用的是19.03.1 2. 安裝docker-compose curl -L https://get.daocloud.io/docke...
1. 概念 Scheduler- 定時(shí)任務(wù)的調(diào)度器,定義了定時(shí)任務(wù)的外部交互接口。 Job - 需要執(zhí)行的任務(wù)必須要集成該接口,并實(shí)現(xiàn)excute方法,任務(wù)邏輯包含在excu...
使用Zookeeper實(shí)現(xiàn)分布式緩存 問題背景 在項(xiàng)目開發(fā)過程中,需要存儲對象型緩存,然而目前的分布式緩存方案redis之類的,緩存服務(wù)器存儲的都是序列化過后的數(shù)據(jù),在使用時(shí)...
kafka部署的問題 1. 連接zookeeper超時(shí) kafka.zookeeper.ZooKeeperClientTimeoutException: Timed out ...
1. 在啟動(dòng)時(shí),start-dfs.sh start-yarn.sh時(shí)報(bào)錯(cuò) Starting namenodes on [namenode]ERROR: Attempting...
@咔嘰咔嘰_ 記錯(cuò)了,是生產(chǎn)消息可以設(shè)置
面試官問:為什么kafka這么快,又能保證消息不丟失?小菜雞最近在瘋狂面試中,就是為了能拿到一份滿意的offer,這不上周又去頭條受虐了。 面試過程中,由于小菜雞的充分準(zhǔn)備(letcode各種刷),各種算法題不在話下,順利的通過...
kafka的消息消費(fèi)可以設(shè)置至少一次,最多一次,恰好一次
面試官問:為什么kafka這么快,又能保證消息不丟失?小菜雞最近在瘋狂面試中,就是為了能拿到一份滿意的offer,這不上周又去頭條受虐了。 面試過程中,由于小菜雞的充分準(zhǔn)備(letcode各種刷),各種算法題不在話下,順利的通過...