没有项目描述
py-confluent的Python项目详细描述
py合流
将ksql、kafka流、模式注册表api引入python 3, 一个干净的包裹。
安装
pip install pyconfluent
使用量
pyconfluent要求运行底层的kafka服务。这个 最简单的方法是启动汇合平台,请参见:``。
ksql
import KSQL
client = KSQL() # enter your boostrap_server here if not 'localhost', no port
client.