Pengembangan Skrip / Objek Konektor DFF.CONN / Kafka

Objek operasi Konektor Kafka terutama menyediakan beberapa metode untuk mengoperasikan Kafka.

Parameter DFF.CONN(...) adalah sebagai berikut:

Parameter	Tipe	Wajib / Nilai Default	Keterangan
connector_id	str	Wajib	ID Konektor

Langganan Pesan

Untuk informasi tentang langganan pesan di Konektor, lihat Pengembangan Skrip / Langganan Konektor

.publish(...)

Mempublikasikan pesan dan menunggu Kafka mengonfirmasi hasil pengiriman, parameternya sebagai berikut:

Parameter	Tipe	Wajib / Nilai Default	Keterangan
topic	str	Wajib	Topik
message	str/bytes	Wajib	Isi pesan; string dikodekan dalam UTF-8

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

Jika pengiriman berhasil, mengembalikan None; jika koneksi atau pengiriman gagal, akan melempar pengecualian.