Sends each row of a project table to an Apache Kafka topic as one message. A sent message can’t be taken back, so running the step again sends the rows again. The step reaches Kafka through an Apache Kafka connection.
| Setting |
Required |
What it does |
| Source Table |
Yes |
The table to send. |
| Kafka Connection |
Yes |
The connection to send through. |
| Topic |
Yes |
The topic every row is sent to. |
| Setting |
What it does |
| Key Column |
The column whose value is the message key. Leave it blank to send messages without a key. |
| Value Columns |
The comma-separated columns that make up the message value. Leave it blank to send every column. |
| Partition Column |
An integer column that names the partition for each message. Leave it blank to let Kafka choose. |
| Value Format |
JSON, Text, or Avro. |
| Avro Schema (JSON) |
The Avro schema of the message value. Required when the format is Avro. |
| Setting |
Default |
What it does |
| Delivery Wait (Seconds) |
60 |
How long the step waits at the end for Kafka to confirm every message. |
| Time Limit (Seconds) |
10800 |
The longest the send may run. |
| Extra Producer Settings (JSON) |
— |
Additional Kafka producer settings as a JSON object, such as {"compression.type": "gzip"}. Only settings PlaidCloud allows are accepted. |