创建项目 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大家都知道，对于后端开发工程师来说，其中一项很重要的工作就是：如何把一个接口设计好。其实不管是什么编程语言，Java、Go还是C++，其背后的后端思想其实都是类似的。所以，今天我们就用一篇文章的篇幅来给大家详细梳理总结一下：设计好接口的36个锦囊，应该说非常全面了，希望看完能对大家的日常工作有所帮助。掌握了这些技巧，写出来的代码也会更加清新优雅。 1. 接口参数校验 入参出参校验是每个程序员必备的…
Leave a Comment手上有一个打印机，它的位置有点尴尬，没法连接网线。打印机也是不支持WiFi的，它只支持连接以太网或者usb连接。 手上有个X86小机器，他有usb口和无线网卡，我帮设备安装了Ubuntu系统，尝试用这个Ubuntu系统帮打印机共享出来。 查看打印机 可以看到，系统已经认到我插的USB打印机了。 使用lpstat -p命令也能看到我们的打印机正常识别，现在只要帮他共享出去即可。 我们可以通过 htt…
Leave a Comment主要是用 kafka-consumer-groups.sh 这个指令。 –bootstrap-server localhost:9092 –group consumerGroupId 主要是指定要操作的集群和消费者组， –describe可以看到当前消费的主题列表和偏移量情况。 –bootstrap-server localhost:9092 –group consumerGr…
Leave a Comment