在此添加简短描述!

kafka-tfrx的Python项目详细描述


[![生成状态](https://travis-ci.org/kryptoflow/kafka-tfrx.svg?branch=master)](https://travis-ci.org/kryptoflow/kafka-tfrx

简单、惯用的python api,用于将kafka主题与[rxpy](https://github.com/ReactiveX/RxPY)接口

##说明

这个库的目标主要是实现对卡夫卡主题的被动访问。它建立在融合卡夫卡的基础上 python[client](https://github.com/confluentinc/confluent-kafka-python),并允许从 任何卡夫卡的话题。

这个图书馆的主要动机是将它与[在线学习](https://en.wikipedia.org/wiki/Online_machine_learning)结合使用, 但这绝不限于此。在某种程度上,它提供了kafka streams提供的功能的子集, 目前还没有一个稳定的python实现。

##用法

参见示例

##测试

从顶层目录运行tox

##注意

此项目是使用Pyscaffold 3.0.3设置的。详情和 pyscaffold的使用信息请参见<;http://pyscaffold.org/>;。

欢迎加入QQ群-->: 979659372 Python中文网_新手群

推荐PyPI第三方库


热门话题
java iText字体显示不正确   java使用ApacheFTPClient通过代理连接到FTP服务器   java是在类常量池、字符串池还是年轻一代中为字符串文本分配的空间?GC何时可以访问字符串文字?   java如何读取excel文件并将值设置为null   验证。包含在Java中不用于验证电子邮件格式的(“@”)   两个服务器实例上的java Hibernate主键冲突   java我无法在For循环(JavaFX)中设置按钮文本   单独SocketChannels的java并发读取()对于大型字节缓冲区速度较慢   OpenPDF java分组元素以保持在同一页面上   java将组件放置在任意(x,y)坐标处   java Jackson不会序列化hibernate惰性抓取字段   从Eclipse将带有库的java项目导出到可运行jar   java为什么会出现{错误?   java如何将线性布局(作为子布局)动态添加到约束布局(父布局)?