中間件 - 專題 - 簡(jiǎn)書

投稿

中間件

收錄了11篇文章 · 1人關(guān)注

Kafka的ack機(jī)制
ack=0/1/-1的不同情況：0：producer不等待broker的ack，broker一接收到還沒有寫入磁盤就已經(jīng)返回竖伯，當(dāng)broker故障...

香山上的麻雀 0 0
實(shí)時(shí)同步mysql數(shù)據(jù)到Elasticsearch（3.消費(fèi)Kafka消息同步數(shù)據(jù)到ES）
1宽堆、導(dǎo)入maven引用 2麦萤、配置文件如下： 3削锰、初始化Jest客戶端 4坡贺、實(shí)現(xiàn)Kafka批量消費(fèi) 5厦滤、實(shí)現(xiàn)ES 通用業(yè)務(wù)邏輯層 6次兆、實(shí)現(xiàn)消費(fèi)邏輯...

0.7 香山上的麻雀 0 4

Flink消費(fèi)Kafka數(shù)據(jù)時(shí)指定offset的五種方式
下面是Flink讀取Kafka數(shù)據(jù)的代碼稿茉，其中就有五種讀取offset的方式，并配置相應(yīng)的介紹

0.8 香山上的麻雀 0 3
kafka 修改副本數(shù)
本文完全參考官網(wǎng)：官網(wǎng)鏈接：https://kafka.apache.org/21/documentation.html#basic_ops_i...

0.1 香山上的麻雀 0 1
Kafka auto.offset.reset值詳解
昨天在寫一個(gè)java消費(fèi)kafka數(shù)據(jù)的實(shí)例芥炭，明明設(shè)置auto.offset.reset為earliest漓库，但還是不從頭開始消費(fèi)，官網(wǎng)給出的含義...

0.1 香山上的麻雀 0 1
Kafka攔截器（interceptor）功能
Producer攔截器(interceptor)是在Kafka 0.10版本被引入的园蝠，主要用于實(shí)現(xiàn)clients端的定制化控制邏輯渺蒿。對(duì)于prod...

香山上的麻雀 0 0
實(shí)時(shí)同步mysql數(shù)據(jù)到Elasticsearch（2.Binlog日志生產(chǎn)消息到Kafka）
BinlogMiddleware服務(wù)主要負(fù)責(zé)監(jiān)聽Binlog日志，并將其發(fā)送到Kafka隊(duì)列（及Kafka生產(chǎn)者）彪薛。本示例模擬監(jiān)聽teemol...

0.6 香山上的麻雀 1 1

Kafka 消費(fèi)者遠(yuǎn)程讀不到數(shù)據(jù)
kafka遠(yuǎn)程消費(fèi)不到數(shù)據(jù),但是也不報(bào)錯(cuò)遠(yuǎn)程主機(jī)用telnet命令去測(cè)試kafka以及zookeeper節(jié)點(diǎn)的9200端口以及2181端口都暢通...

0.2 香山上的麻雀 0 2
Flink+Kafka 0.11端到端精確一次處理語(yǔ)義實(shí)現(xiàn)
2017年12月Apache Flink社區(qū)發(fā)布了1.4版本茂装。該版本正式引入了一個(gè)里程碑式的功能：兩階段提交Sink，即TwoPhaseComm...

0.6 香山上的麻雀 0 3
用Kafka自帶腳本實(shí)現(xiàn)Kafka消費(fèi)情況實(shí)時(shí)監(jiān)控
查看consumer組內(nèi)消費(fèi)的offset 在${KAFKA_HOME}/bin下./kafka-run-class.sh kafka.tool...

0.5 香山上的麻雀 0 3