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