1. 你需要配置好Kafka和zookeeper 1.1 JDK的安裝與配置(請(qǐng)自行Google) 1.2 Zookeeper的安裝與配置(請(qǐng)自行Google) ...
發(fā)簡(jiǎn)信
IP屬地：北京
-
mac如何使用Kafka-eagle監(jiān)控Kafka（本地單機(jī)案例） -
Flink如何自定義一個(gè)定時(shí)數(shù)據(jù)源
不廢話，直接上代碼，賊傻，需要什么修改自己加就完事了！?。。。。?DataStream timerStream = env.addSource(new TimerSource...
-
Flink如何實(shí)現(xiàn)一個(gè)某種數(shù)據(jù)缺失半小時(shí)觸發(fā)報(bào)警的監(jiān)控問題定義：半小時(shí)監(jiān)控可以定義為整間隔時(shí)間（如9:00-9:30），也可以定義為某條數(shù)據(jù)之后的半小時(shí) 提示：若采用processingtime，我們可以在env中設(shè)置自動(dòng)定時(shí)產(chǎn)...
-
hive中對(duì)多行進(jìn)行合并—collect_set&collect_list函數(shù)
最近在做項(xiàng)目的時(shí)候需要對(duì)數(shù)據(jù)組埋點(diǎn)得到的數(shù)據(jù)進(jìn)行合并： 1.原始數(shù)據(jù)我需要拿到post_id,district_id字段，而一個(gè)post可能投放到同一城市的多個(gè)distric...
-
如何在k8s上搭建zookeeper集群
1.配置k8s集群的config文件----具體文件內(nèi)容自行搜索 2.安裝kubectl 3.創(chuàng)建svc和deployment配置文件 鏈接:https://pan.baid...
-
在k8s上如何使zookeeper打印DEBUG級(jí)別日志1.請(qǐng)注意kubectl的版本，版本不匹配可能造成一系列問題，我們采用的使client：v1.15.1，server：v1.16.0（請(qǐng)注意1.15.1的版本的yaml文件中...
-
scala 如何向RabbitMQ隊(duì)列寫消息（生產(chǎn)者）
1.首先，你需要一個(gè)RabbitMQ客戶端的jar包 鏈接: https://pan.baidu.com/s/1JFZ7jblpAIsQ29k2pSaxDA 提取碼: w1m...
個(gè)人介紹
一個(gè)AI起步失敗,又轉(zhuǎn)身一頭扎進(jìn)大數(shù)據(jù)的屌絲。。?，F(xiàn)在我tm成項(xiàng)目經(jīng)理了。。。東一榔頭，西一棒槌。。。