
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ì)不同,語法會(huì)有差異,本文默認(rèn)String 保存為keyword類型永罚,詳細(xì)了解移步Elasti...
使用示例 結(jié)果
1.實(shí)現(xiàn)BatchErrorHandler 2.注冊進(jìn)KafkaListenerContainerFactory中
一個(gè)特殊需求悯森,需要數(shù)據(jù)庫實(shí)體對象轉(zhuǎn)換成json的時(shí)候,key為數(shù)據(jù)庫原表字段撕瞧,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)類