スクリプト開発 / コネクターオブジェクト 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 を返し、接続または送信失敗時は例外をスローします。