【文件属性】：
文件名称：kafka-tfrx:简单的库，用于将Kafka与RxPY接口
文件大小：21KB
文件格式：ZIP
更新时间：2021-05-01 01:07:27
Python
卡夫卡-tfrx
简单，惯用的python API，可将Kafka主题与接口
描述
该库的目标主要是使对Kafka主题的React式访问成为可能。 它基于Confluent Kafka的python构建，并允许从任何Kafka主题构建可观察的流。
该库的主要动机是通过使用它，但绝不仅限于此。 在某种程度上，它提供了Kafka-Streams提供的功能的子集，该功能目前还没有稳定的python实现。
用法
参见examples/
测验
从顶层目录运行tox
笔记
该项目是使用PyScaffold 3.0.3设置的。 有关PyScaffold的详细信息和使用信息，请参见 。
【文件预览】：
kafka-tfrx-master
----kafka_tfrx()
--------__init__.py(46B)
--------observer.py(849B)
--------stream.py(3KB)
----test-requirements.txt(56B)
----LICENSE.txt(1KB)
----requirements.txt(48B)
----examples()
--------simple_consumer.py(413B)
--------simple_producer.py(554B)
--------__init__.py(0B)
--------schemas()
----.travis.yml(1KB)
----tox.ini(135B)
----AUTHORS.md(87B)
----setup.cfg(2KB)
----setup.py(811B)
----README.md(1KB)
----docs()
--------authors.rst(41B)
--------conf.py(9KB)
--------index.rst(2KB)
--------Makefile(7KB)
--------license.rst(74B)
--------changelog.rst(43B)
--------_static()
----tests()
--------__init__.py(0B)
--------conftest.py(318B)
--------sample_schemas()
--------test_setup_streamer.py(2KB)
----.gitignore(445B)
----CHANGELOG.md(129B)
----.coveragerc(549B)