我的诉求是,我现在kafka上面有个实时是数据流,他是一个接口的请求日志。 我现在想要实时分析出来每个接口的访问频次和延迟,我还想按照系统的维度统计访问频次和延迟。 就是说我想对同一个数据源进行初始过滤,然后对数据流进行分支,然后分别计算我想要的数据。
Leave a Comment作者: admin
1.系统配置-软件更新-高级,帮里面的勾选都去掉 2.移除系统配置上面那个升级的小提示 这个小提示只是临时移除,如果你重新打开系统软件升级页面,这个小提示还会再出来。。。
Leave a Comment我的mac电脑有点老,随着系统的升级感觉越来越不好用了,想了想,也看到网上别人的评价,感觉那个Mojave系统还是不错的,想降级到这个系统。 直接在苹果商店搜索 “macOS Mojave”,能找到这个系统: https://apps.apple.com/us/app/macos-mojave/id1398502828?mt=12 我们的mac可以正常下载下来,但是安装的时候会报错: 大概的意思是…
Leave a Comment创建项目 idea新建项目,Archetype选择:org.apache.maven.archetypes:maven-archetype-quickstart 项目创建好之后,pom依赖补充一些flink相关的,日志相关的和打包相关的依赖: 这里是个简单聚合统计场景,按照接口统计每分钟的调用频次。 用maven进行项目打包之后会出来个几十兆的大的jar包,帮他上传到flink集群的job里面,然…
Leave a Comment需要注意帮 DOCKER_HOST_IP 配置成外部可以访问你容器的ip地址,直接修改DOCKER_HOST_IP或者后面的 127.0.0.1都可以。如果这个不修改,外部访问你这个kafka可能会有问题。 参考资料: https://github.com/conduktor/kafka-stack-docker-compose.git
Leave a Comment参考资料: https://nightlies.apache.org/flink/flink-docs-master/docs/deployment/resource-providers/standalone/docker/#app-cluster-yml
Leave a Comment最近要实现一个基于kafka的流数据处理,需要一个本地的kafka开发环境,有一些在线的测试数据。 项目结构: main.py config.ini Dockerfile docker-compose.yml 编译好镜像直接运行即可,配置指定好测试数据位置和kafka位置。
Leave a Comment接前面文章:类似 VMware的Unity 模式的远程桌面(远程APP)体验 https://www.xiaocaicai.com/2024/01/%e7%b1%bb%e4%bc%bc-vmware%e7%9a%84unity-%e6%a8%a1%e5%bc%8f%e7%9a%84%e8%bf%9c%e7%a8%8b%e6%a1%8c%e9%9d%a2%ef%bc%88%e8%bf%9c%e7%a…
Leave a Comment参考资料: https://stackoverflow.com/questions/54429210/how-do-i-prevent-conda-from-activating-the-base-environment-by-default
Leave a Comment你可以使用 Mac 上的内建恢复系统“macOS 恢复”来重新安装 macOS。“macOS 恢复”会在重新安装期间保留你的文件和用户设置不变。 【重要事项】你的电脑必须接入互联网,才能重新安装 macOS。 在搭载 Apple 芯片的 Mac 或搭载 Apple T2 安全芯片且基于 Intel 的 Mac 上,在折抵换购或出售前,使用“抹掉助理”将 Mac 还原至出厂设置。请参阅抹掉 Mac。…
Leave a Comment