Script Development / Connector Object DFF.CONN / Kafka
The Kafka connector operation object mainly provides methods for operating Kafka.
The parameters for DFF.CONN(...) are as follows:
| Parameter | Type | Required / Default | Description |
|---|---|---|---|
connector_id |
str | Required | Connector ID |
Message Subscription
For message subscription in the connector, please refer to Script Development / Connector Subscription
.publish(...)
Publish a message and wait for Kafka to confirm the sending result. The parameters are as follows:
| Parameter | Type | Required / Default | Description |
|---|---|---|---|
topic |
str | Required | Topic |
message |
str/bytes | Required | Message content; strings are encoded in UTF-8 |
| Example | |
|---|---|
1 | |
Returns None on successful sending; throws an exception if the connection or sending fails.