component-flow
2018-06-19 10:41:32 2 举报cpp-process
作者其他创作
大纲/内容
为事件生成唯一id并转发事件到kafka集群
是
记录非法格式事件到文件
重试超过指定次数
事件是合法的json格式
内部处理流程细节请看 spark application处理流程图
bmc cell调用 curl 重试脚本 发送事件到 kafa-agent
event
成功发送
kafka收到新的事件
spark application 监听到kafka新事件拉取并处理事件
否
kafka agent接收到 event 并简单处理
记录发送失败的事件到文件做后续处理
事件从bmc到复杂事件处理平台流传流程
收藏
0 条评论
下一页
