新闻流式服务是公司内部新闻分析的基础服务，集成新闻分析服务，后抽取作为一个对外的 API 以及产品试用样式开放，主要是接受新闻分析服务的结果，以定义规则存入 kafka 并对外推送，规则 id 存入redis。上游为新闻分析服务，新闻分析服务调用算法完成解析后往下游推送，该系统根据每个开通账号定义的规则提取不同的新闻内容以及标签，将对应的新闻推送至 kafka 并由客户使用账号以 consumer消费消息。