---
sourceDocument: Australia Build workflows
sourceDocumentLink: https://servicenow-prod.fluidtopics.net/r/build-workflows

 Release :

    - australia

ft:locale :

    - en-US

ft:publication_title :

    - Australia Build workflows

ft:clusterId :

    - crworkflow

bundleId :

    - crworkflow

workflow :

    - Creator


---

# Kafka Producer step

# Kafka Producer step {#ariaid-title1}

* Release version: Australia
* 
* Updated March 12, 2026
* 
* ![](https://www.servicenow.com/docs/portal-asset/ico-clock) 2 minutes to read

Summarize  
![AI sparkle icon](https://servicenow.com/docs/portal-asset/ai-sparkle-icon) Summarized using AI  
This content was generated using new OpenAI-powered functionality. Results are provided on an as is basis and are not guaranteed to be accurate or complete.  

## Summary of Kafka Producer step

The Kafka Producer step is a Workflow Studio action that enables ServiceNow customers to publish events to topics within their Kafka environment.
It requires the Stream Connect subscription and the ServiceNow Stream Connect Installer plugin.
Users with theactiondesignerrole can create custom actions incorporating this step.
Show full answer Show less  

## Key Features

* **Topic Alias:** Select a unique topic alias from a drop-down list to specify the target Kafka topic for message publishing.
* **Message:** Define the text content of the message to be published.
* **Key:** Specify a key to determine the partition where the message will be stored---messages with the same key are routed to the same partition.
* **Headers:** Add message headers as name-value pairs, supporting static values or dynamic data pills.
* **Wait For Completion:** Optionally configure the flow to pause until the Kafka Producer step completes before continuing.
* **Schema:** Select a schema to validate message structure, ensuring the message adheres to the schema definition for consistent data formatting.
* **If this step fails:** Choose whether to stop the action and proceed to error evaluation or continue to the next step despite errors. The error information is always captured in the Step Status object.

## Outputs

* **Step Status Object:** Contains runtime details including:
  * **Code:** Integer indicating success (0) or error (1) of the step execution.
  * **Message:** String containing any error messages generated by the step.

## Practical Use

This step allows customers to seamlessly integrate ServiceNow workflows with Kafka by publishing structured event messages to Kafka topics. For example, it can send incident creation events with identifiers and descriptions to a designated Kafka topic, enabling real-time event streaming and integration with other systems.  
Create an action that publishes events to a topic in your Kafka environment.

## Roles and availability {#kafka-producer-action-designer__section_uqv_nbp_frb}

The Kafka Producer step is an Workflow Studio action step. Users with the
action_designer role can create a custom action with one or more action steps.

This step is requires a Stream Connect subscription. For more information, see <https://www.servicenow.com/now-platform/workflow-data-fabric.html>.

This step requires the ServiceNow Stream Connect Installer \[com.glide.hub.stream_connect.installer\] plugin.

## Fields {#kafka-producer-action-designer__section_gqs_4bp_frb}

{#kafka-producer-action-designer__table_sxk_5bp_frb__entry__2}

| Field | Description |
|-|-|
| Topic Alias | Name of the topic alias for the topic you want to publish messages to. A topic alias is a unique topic name that can be connected to any underlying Hermes or Direct Kafka topic. Select a topic alias from the drop-down list. |
| Message | Text of the message. |
| Key | Name of the key for a specific partition. Topics can be partitioned. Messages with the same key are stored in the same partition. For example, payment messages with a key of June would all be stored in the same partition of the Payments topic. |
| Headers | Headers for the message, in name-value pairs. For both the Name and Value fields, you can enter a value or use a data pill. |
| Wait For Completion | Option to require the flow to wait for the step to complete before continuing. |
| Schema | Reference to a schema table. Select a schema from the list. For information on schemas, see [Schema management in Stream Connect](https://www.servicenow.com/docs/access?context=schema-management&version=australia&pubname=australia-integrate-applications&ft:locale=en-US). Note: The message you're sending in the Message field must adhere to the structure of the selected schema. |
| If this step fails | Option to go to error evaluation or continue running the next step. This option has no effect on the Step Status. Select one of the following. * Stop the action and go to error evaluation: Stop running the action at the current step and go to error evaluation. The Step Status object contains the error information returned by the step. * Don't stop the action and go to the next step: Ignore the failure and continue running the action from the next step. The Step Status object contains the error information returned by the step. Action error evaluation runs regardless of whether the action continues running. {#kafka-producer-action-designer__ul_mk3_bkw_frb} |
[ ]

{#kafka-producer-action-designer__table_sxk_5bp_frb}

## Example {#kafka-producer-action-designer__section_ekk_pbp_frb}

In this example, the step sends a message recording the creation of an incident. The message includes an incident identifier, a description, and a message header. The message is sent to the incidents topic, and stored in the
partition with the name of the incident identifier.

## Outputs {#kafka-producer-action-designer__section_dqw_pbp_frb}

{#kafka-producer-action-designer__table_ulc_wbp_frb__entry__3}

| Field | Description | Data Type |
|-|-|-|
| Step Status | Object data pill containing runtime details about the step. Each step in an action returns a Step Status. | Object |
| Step Status \> Code | Integer data pill indicating whether the step produced an error. By default, a value of 1 indicates that the step produced an error. A value of 0 indicates that the step ran successfully. You can't customize these codes. | Integer |
| Step Status \> Message | String data pill containing the error message produced by the step or system operation. You can't customize this message. | String |
[ ]

{#kafka-producer-action-designer__table_ulc_wbp_frb}