LinkedBlockingQueue 是很優(yōu)秀的阻塞隊(duì)列實(shí)現(xiàn),某些資料顯示可以達(dá)到50w QPS左右,其讀寫使用兩把鎖,但底層使用Reentr...
1.導(dǎo)包 2.Kafka配置類 3.配置文件(application.properties) 3.定義Consumer類 4.定義kafka-t...
聲明:本文為方便日后部分DSL結(jié)構(gòu)速查,由于索引設(shè)計(jì)不同,語(yǔ)法會(huì)有差異,本文默認(rèn)String 保存為keyword類型,詳細(xì)了解移步Elasti...
使用示例 結(jié)果
1.實(shí)現(xiàn)BatchErrorHandler 2.注冊(cè)進(jìn)KafkaListenerContainerFactory中
一個(gè)特殊需求,需要數(shù)據(jù)庫(kù)實(shí)體對(duì)象轉(zhuǎn)換成json的時(shí)候,key為數(shù)據(jù)庫(kù)原表字段,value Date 轉(zhuǎn)String,找了找博客,看了看fastj...
包含*字符的自己替換
寫在前面:Presto 是facebook開發(fā)的一款開源大數(shù)據(jù)OLAP引擎,基于內(nèi)存計(jì)算和作業(yè)分發(fā),直接使用sql分析,不需要數(shù)據(jù)預(yù)處理,類似于...
1.pom中映入starter 2.啟動(dòng)類