Create Topic

managed_kafka.create_topic

ActionGoogle Cloudconnection required

Calls managedkafka v1 POST /v1/projects/{projectsId}/locations/{locationsId}/clusters/{clustersId}/topics.

Creates a new topic in a given project and location.

Ask about Google Managed Service for Apache Kafka All Google Managed Service for Apache Kafka nodes Provider API docs ↗

Connection

Required: Yes — the node will not save without one
Auth type: OAuth 2.0
Providers: Google Managed Service for Apache Kafka
Secret shape: {"client_id", "client_secret", "refresh_token"}
Config it needs: project_id, location
Resolved by: config.connection_id, else node.connection_id

Configuration

4 fields, 3 required. A dotted path is a nested object and name[] an array of objects — the editor renders the same tree.

Field	Type	Required	Default	Constraints	Example
location Location or region; taken from the connection when unset.	string	No	—	—	—
cluster Cluster name or id.	string	Yes	—	—	—
body The Topic resource, as the API defines it.	object	Yes	—	—	—
topic_id The ID to use for the topic, which will become the final component of the topic's name. Required.	string	Yes	—	—	—

Output

One shape.

result

Extra keys beyond the ones listed can appear.

Field	Type	Example
configs	object	—
name	string	—
partitionCount	integer	—
replicationFactor	integer	—

{
  "configs": {},
  "name": "",
  "partitionCount": 0,
  "replicationFactor": 0
}

Related Google Managed Service for Apache Kafka nodes

See Create Topic run in a workflow.

In a technical demo we add the Google Managed Service for Apache Kafka connection, drop the node on the canvas and let Workflow Health pre-flight it before the first real run.

Book a technical demo Talk to sales