脚本开发 / Kafka

Kafka 连接器操作对象主要提供一些操作 Kafka 的方法。

DFF.CONN(...)参数如下：

参数	类型	必须/默认值	说明
connector_id	str	必须	连接器 ID

.publish(...)

publish(...)方法用于发布消息，参数如下：

参数	类型	必须/默认值	说明
topic	str	必须	主题
message	str	必须	消息内容