脚本开发 / 连接器对象 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；连接或发送失败时抛出异常。