【文件属性】:
文件名称:kafka-connect-python:Kafka Connect REST API的Python模块
文件大小:6KB
文件格式:ZIP
更新时间:2021-05-16 17:19:53
Python
kafka连接python
Kafka Connect REST API的Python模块
要求
巨蟒(3.6)
安装
使用pip安装...
pip install kafka-connect-python
例子
创建KafkaConnect REST接口
from kafka_connect import KafkaConnect
connect = KafkaConnect ( host = 'localhost' , port = 8083 , scheme = 'http' )
print ( connect . api . version )
使用配置字典创建连接器
config = {
"connector.class" : "io.confluent.connect.jdbc.JdbcSourceConnector" ,
"connection
【文件预览】:
kafka-connect-python-master
----MANIFEST.in(82B)
----kafka_connect()
--------__init__.py(8KB)
----LICENSE(1KB)
----setup.cfg(110B)
----setup.py(548B)
----README.md(1KB)
----Makefile(334B)
----.gitignore(132B)