脚本开发 / Kafka

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

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

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

消息订阅

有关在连接器中进行消息订阅，请参考 脚本开发 / 连接器订阅

.publish(...)

发布消息，参数如下：

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