开发工具:
文件大小: 322kb
下载次数: 0
上传时间: 2021-02-19
详细说明：流量
防弹数据流处理框架
KFlow是考虑到Kafka构建的Erlang数据流DSL。 使用Kflow实现的服务具有以下属性：
无状态。 可以随时重新启动服务，而不会丢失数据
容错和自我修复。 可以修复服务中的任何崩溃，一旦部署了该修复程序，该服务将自动重播导致崩溃的数据。 这可以进行无所畏惧的A / B测试和金丝雀部署
可扩展
自动并行化。 每个转换并行运行
自动背压。
这是通过KFlow行为中内置的相当复杂的偏移量跟踪逻辑来实现的，该逻辑可确保仅在完全处理输入消息时才将使用者偏移量提交给Kafka。
KFlow的另一个功能是“虚拟分区”，该功能允许将Kafka分区拆分为许多独立处理的子流。
使用范例
使用名为kflow_config.erl的特殊Erlang模块配置kflow_config.erl 。 此模块必须导出pipes/0函数，以返回工作流列表。 例如：
- modu
(系统自动生成,下载前可以参看下载内容)
下载文件列表
相关说明
- 本站资源为会员上传分享交流与学习,如有侵犯您的权益,请联系我们删除.
- 本站是交换下载平台，提供交流渠道，下载内容来自于网络，除下载问题外，其它问题请自行百度。
- 本站已设置防盗链，请勿用迅雷、QQ旋风等多线程下载软件下载资源，下载后用WinRAR最新版进行解压.
- 如果您发现内容无法下载，请稍后再次尝试；或者到消费记录里找到下载记录反馈给我们.
- 下载后发现下载的内容跟说明不相乎，请到消费记录里找到下载记录反馈给我们，经确认后退回积分.
- 如下载前有疑问，可以通过点击"提供者"的名字，查看对方的联系方式，联系对方咨询.
