Beam Kafka Produce


The Beam Kafka Produce transform publishes records to a Kafka cluster using the Beam execution engine.


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.