轻量化收集日志

背景

最近在做一个项目,需要收集日志/埋点数据,需求是轻量化收集

正常我们的项目的埋点或者日志都是想方设法发送到生产端的kafka节点,但是kafkajava服务过于吃性能了

方案

由研发让服务写到本地文件

运维使用filebeat发送到redis,然后在用vector消费入库

也就是在生产端只要运行filebeatredis即可

实现

我把实现放在了这里