Beam Kafka Produce
Description
The Beam Kafka Produce transform publishes records to a Kafka cluster using the Beam execution engine.
Options
| Option | Description |
|---|---|
Transform name | Name of the transform, this name has to be unique in a single pipeline. |
Bootstrap servers | A comma separated list of hosts which are Kafka brokers in a "bootstrap" Kafka cluster. |
The topics | The topics to publish to. |
The field to use as key | The record key. |
The field to use as message | The record message. |