發(fā)簡(jiǎn)信
IP屬地：福建
-
python導(dǎo)包錯(cuò)誤 ImportError: cannot import name a
開發(fā)工具pycharm 運(yùn)行方式 pycharm右鍵運(yùn)行 python命令執(zhí)行 項(xiàng)目目錄結(jié)構(gòu)cloud_platform 代碼 問題 在pych...
-
kafka消息格式
kafka發(fā)送消息是有消息格式的，有三個(gè)版本V0,V1,V2 V0版本：主要指kafka0.10.0.0之前的版本，是kafka最早的消息版本，...
-
sparkStreaming拉取kafka010的bug
目前kafka版本中，很多公司在用kafka010，但是在用sparkstreaming去消費(fèi)kafka時(shí)，很多人都會(huì)碰到一個(gè)錯(cuò)誤 解決步驟 根...
-
zookeeper的watcher
利用zk的watcher功能實(shí)時(shí)監(jiān)控zk節(jié)點(diǎn)的變化，可以利用這個(gè)功能做報(bào)警、監(jiān)控，例如監(jiān)控kafka的broker，otter的node等，如果...
-
sparkstreaming將offset存到hbase
之前一直將offset存到zookeeper，由于streaming程序會(huì)對(duì)zk有大量的讀取操作，故將offset存到zk不太好，現(xiàn)已將offs...
-
HikariCP數(shù)據(jù)庫(kù)連接池
快速，簡(jiǎn)單，可靠。HikariCP是一個(gè)“零開銷”生產(chǎn)就緒JDBC連接池。大約130Kb,它的性能幾乎是C3P0、DBCP的25倍，十分強(qiáng)悍引用...
-
kafka刪除topic
刪除kafka topic及其數(shù)據(jù)，嚴(yán)格來說并不是很難的操作。但是，往往給kafka 使用者帶來諸多問題，發(fā)現(xiàn)都會(huì)偶然出現(xiàn)無法徹底刪除kafka...
-
flume監(jiān)控inode變化的文件由于要實(shí)時(shí)讀取redis的AOF文件，但是flume的taildir source在監(jiān)控文件的時(shí)候，如果文件的inode變化了，那么會(huì)出現(xiàn)重復(fù)讀...
-
HBase新版本Java API
HBase新版本Java API 之前沒有碼全，這次增刪改查全乎了，網(wǎng)上有很多例子，自己根據(jù)實(shí)際在用的收集總結(jié)了一下 導(dǎo)入的包 初始化連接對(duì)象 ...