脚本开发 / 连接器对象 DFF.CONN / Kafka

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

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

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

消息订阅

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

.publish(...)

发布消息并等待 Kafka 确认发送结果，参数如下：

参数	类型	必须 / 默认值	说明
topic	str	必须	主题
message	str/bytes	必须	消息内容；字符串按 UTF-8 编码

kafka.publish(topic='events', message='hello')

发送成功时返回 None；连接或发送失败时抛出异常。