LinkedBlockingQueue 是很優(yōu)秀的阻塞隊列實現(xiàn)，某些資料顯示可以達到50w QPS左右民傻，其讀寫使用兩把鎖，但底層使用ReentrantLock 進行阻塞，雖然...
發(fā)簡信
IP屬地：海南
-
利用分區(qū)概念增強阻塞隊列吞吐量
-
Spring-KafkaListener使用
1.導包 2.Kafka配置類 3.配置文件（application.properties） 3.定義Consumer類 4.定義kafka-topic與實體類映射文件kaf...
-
ElasticSearch DSL 簡單梳理
聲明：本文為方便日后部分DSL結(jié)構(gòu)速查漓踢，由于索引設(shè)計不同牵署，語法會有差異,本文默認String 保存為keyword類型，詳細了解移步Elastic Stack 官網(wǎng) http...
-
-
KafkaListener 批量消費異常時回退偏移量
1.實現(xiàn)BatchErrorHandler 2.注冊進KafkaListenerContainerFactory中
-
重寫fastjson序列化方法實現(xiàn)自定義key&value
一個特殊需求喧半，需要數(shù)據(jù)庫實體對象轉(zhuǎn)換成json的時候奴迅，key為數(shù)據(jù)庫原表字段，value Date 轉(zhuǎn)String,找了找博客挺据，看了看fastjson的源碼之后,決定重寫Ja...
-
Presto多協(xié)調(diào)者實現(xiàn)寫在前面：Presto 是facebook開發(fā)的一款開源大數(shù)據(jù)OLAP引擎取具，基于內(nèi)存計算和作業(yè)分發(fā)，直接使用sql分析吴菠，不需要數(shù)據(jù)預處理者填，類似于impala和sparksql...
-
Debezium、kafkaConnect做葵、sqlserver數(shù)據(jù)同步
寫在前面： 我先假設(shè)kafka已經(jīng)安裝好 1.opt 目錄下創(chuàng)建一個文件夾 /opt/kafka-connect-pak 2.去confluent官網(wǎng)下載最新版conflue...
-
java 函數(shù)多返回值
思路一：利用數(shù)組 但這樣指定不清晰占哟，看上去也不怎么優(yōu)雅 思路二：定義Pair對象 函數(shù) 取值： 看上去就舒服多了，舉一反三酿矢，也可以定義Third 對象榨乎，里面有l(wèi)eft ,mi...
-
zabbix 4.0安裝
一：安裝mysql1.查找是否有mysql安裝 rpm -qa | grep -i mysqlrpm -qa | grep -i mariadb 2.安裝依賴yum -y i...
-
zabbix監(jiān)控kudu節(jié)點狀態(tài)1.自定義kudu監(jiān)控腳本cd /etc/zabbix/zabbix_agentd.dvim kudu_listen.sh cd /etc/zabbix/zabbix_age...
-
kudu增刪改查（orm方式）
由于presto對kudu進行數(shù)據(jù)插入過慢，采用kudu-client之后寫入可達每秒10w條瘫筐，所以對kudu-client進行封裝 kudu util工具類 自定義kudu...
-
直接用jdbc執(zhí)行這個語句再取到create table語句的返回值就可以了蜜暑，不過不建議用這份，不嚴謹策肝，當時測試時寫著玩的肛捍，還是建議直接讀取mysql系統(tǒng)表，取到表和字段信息之众，然后轉(zhuǎn)換成clickhouse表結(jié)構(gòu)
mysql表結(jié)構(gòu)轉(zhuǎn)clickhouse 表結(jié)構(gòu)
-
clickhouse集群搭建（1）ClickHouse是一個用于聯(lián)機分析(OLAP)的列式數(shù)據(jù)庫管理系統(tǒng)(DBMS)拙毫。可以用于PB級大數(shù)據(jù)實時分析棺禾，特點呢缀蹄，就是快，比sparksql 和 impala還要快很...