1、项目的功能设计（通过业务打印日志的方式进行告警，通过 filebeat 采集日志发送到 kafka ，日志告警系统通过订阅 kafka的消息对告警进行压制和汇总，对于符合告警策略的进行告警）2、kafka 使用策略设计（filebeat 使用轮询策略发送到 kafka的 partition ，日志告警接受到消息后，会先通过 service和errorCode 进行 hash 存储到对于 partition里，以保证同一个 service 的告警会在一个 partition ；然后日志告警采用 range 订阅策略进行消费。注：统计采用各个日志告警节点自己内存统计，不使用 redis）3、 系统采用多线程进行统计、使用监听器模式计算不同的压制策略4、 使用 kafka的 Rebalance 时间同步数据到数据库，用于确保启停服务时保存内存统计状态5、 系统的推广及个性化需求的修改6、 线上问题的排查及修复