发简信
IP属地：北京
-
mac如何使用Kafka-eagle监控Kafka（本地单机案例）1. 你需要配置好Kafka和zookeeper 1.1 JDK的安装与配置(请自行Google) 1.2 Zookeeper的安装与配...
-
Flink如何实现一个某种数据缺失半小时触发报警的监控问题定义：半小时监控可以定义为整间隔时间（如9:00-9:30），也可以定义为某条数据之后的半小时 提示：若采用processingtime，我...
-
Flink如何自定义一个定时数据源
不废话，直接上代码，贼傻，需要什么修改自己加就完事了！！！！！！ DataStream timerStream = env.addSource(...
-
在k8s上如何使zookeeper打印DEBUG级别日志1.请注意kubectl的版本，版本不匹配可能造成一系列问题，我们采用的使client：v1.15.1，server：v1.16.0（请注意1....
-
如何在k8s上搭建zookeeper集群
1.配置k8s集群的config文件----具体文件内容自行搜索 2.安装kubectl 3.创建svc和deployment配置文件 链接:h...
-
scala 如何向RabbitMQ队列写消息（生产者）
1.首先，你需要一个RabbitMQ客户端的jar包 链接: https://pan.baidu.com/s/1JFZ7jblpAIsQ29k2...
-
hive中对多行进行合并—collect_set&collect_list函数
最近在做项目的时候需要对数据组埋点得到的数据进行合并： 1.原始数据我需要拿到post_id,district_id字段，而一个post可能投放...