为什么需要使用kafka 从本质上来讲,是因为互联网发展太快,使用单体架构无疑会是的体量巨大。而微服务架构可以很好...[作者空间]
Flink checkpoint 一直以来都是 Flink 引以为豪的机制之一,它为 Flink 状态流处理保驾护...[作者空间]
架构 快速开始 一直在寻找一款全能的监控平台,可以满足指标、日志、调用链等多方面一站式观察。Prometheus ...[作者空间]
不废话,直接上东西 由于工程使用maven建立的 pom.xml文件 代码:[作者空间]
1 环境说明 kafka已安装见文档:《kafka单机启动》[https://www.jianshu.com/p/...[作者空间]