最近要实现一个基于kafka的流数据处理，需要一个本地的kafka开发环境，有一些在线的测试数据。 项目结构： [root@localhost KafkaProducer]# ls config.ini docker-comp...
最新博文
python实现一个kafka随机数据生成服务，容器部署
docker-compose运行Flink
version: "3.2" services: jobmanager: image: flink:latest ports: "8081:8081" command: jobmanager environment: FLINK_PROPERTIES= jobmanager.rpc.address: jobman...
docker-compose运行kafka
version: '3.2' services: zoo1: image: confluentinc/cp-zookeeper:7.3.2 hostname: zoo1 container_name: zoo1 ports: "2181:2181" environment: ZOOKEEPER_CLIENT_PO...
使用idea配置一个maven的flink项目消费kafka数据进行流式处理
创建项目 idea新建项目，Archetype选择：org.apache.maven.archetypes:maven-archetype-quickstart 项目创建好之后，pom依赖补充一些flink相关的，日志相关的和打包相关...
Mac安装老版本的系统
我的mac电脑有点老，随着系统的升级感觉越来越不好用了，想了想，也看到网上别人的评价，感觉那个Mojave系统还是不错的，想降级到这个系统。 直接在苹果商店搜索 “macOS...
MacOS移除系统升级提醒
1.系统配置-软件更新-高级，帮里面的勾选都去掉 2.移除系统配置上面那个升级的小提示 defaults write com.apple.systempreferences AttentionPrefBundleIDs 0 killall D...
Flink消费kafka，对同一个数据源进行多维度的实时分析处理
我的诉求是，我现在kafka上面有个实时是数据流，他是一个接口的请求日志。 我现在想要实时分析出来每个接口的访问频次和延迟，我还想按照系统的维度统计访问频次和延迟...
Flink面试，看这篇就足够了
概述 2019 年是大数据实时计算领域最不平凡的一年，2019 年 1 月阿里巴巴 Blink （内部的 Flink 分支版本）开源，大数据领域一夜间从 Spark 独步天下走向了两强争霸的时...
硬核！一文学完Flink流计算常用算子,Flink算子大全
直入正题！ Flink和Spark类似，也是一种一站式处理的框架；既可以进行批处理（DataSet），也可以进行实时处理（DataStream）。 所以下面将Flink的算子分为两大类：一类...
python脚本监控家里电视是否开机及开机时常
家里小朋友放学会自己打开电视看，需要控制小朋友看电视时常，写一个脚本来进行监控。 #!/usr/bin/python -- coding: UTF-8 -- import subprocess import time import r...