goflow 可以让我们基于flow的模式进行数据的处理,是flow-based 编程指南的golang 参考实现 
使用上简单,而且比较高效,同时我们也可以集成kafka 增强flow 的分布式处理能力

参考资料

https://github.com/trustmaster/goflow 
https://github.com/flowbased/flowbased.org 
https://flow-based.org/ 
https://jpaulm.github.io/fbp/