Producer and Consumer Library For Stream Processing#
Note
我有一个开源项目 unistream, 是一个 Producer and Consumer Library For Stream Processing 的框架. 把所要用到的模块全部抽象化了, 例如 producer 需要的 buffer, consumer 需要的 checkpoint 等. 使得我们可以用任何后端系统实现这些模块, 并于任何 Stream system 集成.
What is Producer Library#
What is Consumer Library#
Consumer Library 是一个客户端程序, 它能从 Stream 中读取数据, 并对数据进行处理.