---
title: ProducerV2 - Scoped
description: The ProducerV2 API provides methods to publish messages from your ServiceNow instance to a Kafka topic.Sends the specified message to the specified Kafka topic.
locale: en-US
canonical_url: https://www.servicenow.com/docs/r/australia/api-reference/server-api-reference/ProducerV2ScopedAPI.html
release: australia
product: Server API Reference
classification: server-api-reference
topic_type: concept
last_updated: "2026-03-12"
reading_time_minutes: 2
breadcrumb: [Server API reference, API reference, API implementation and reference]
---

# ProducerV2- Scoped

The ProducerV2 API provides methods to publish messages from your ServiceNow instance to a Kafka topic.

**Note:** This API requires a Stream Connect subscription. For more information, see [https://www.servicenow.com/now-platform/workflow-data-fabric.html](https://www.servicenow.com/now-platform/workflow-data-fabric.html).

This API requires the ServiceNow Stream Connect Installer plugin \(com.glide.hub.stream\_connect.installer\) and runs in the `sn_ih_kafka` namespace.

**Parent Topic:**[Server API reference](https://raw.githubusercontent.com/ServiceNow/ServiceNowDocs/australia/markdown/australia/api-reference/server-api-reference/api-server.md)

## ProducerV2 - send\(String topicSysID, String key, String message, Boolean isSync, Object headers, String schemaID\)

Sends the specified message to the specified Kafka topic.

<table id="table_vn5_c3f_nvb" class="parameters"><thead><tr><th>

Name

</th><th>

Type

</th><th>

Description

</th></tr></thead><tbody><tr><td>

topicSysID

</td><td>

String

</td><td>

Sys\_id of the topic to publish the message to. Topics are stored in the Kafka Topics \[sys\_kafka\_topic\] table.

</td></tr><tr><td>

key

</td><td>

String

</td><td>

Name of the key for a specific partition in the topic.

</td></tr><tr><td>

message

</td><td>

String

</td><td>

Message text.

</td></tr><tr><td>

isSync

</td><td>

Boolean

</td><td>

Flag that indicates whether to require the script to wait for the send method to complete before continuing.Valid values:

-   true: Wait for the step to complete before continuing the associated flow.
-   false: Do not wait for the step to complete before continuing the associated flow.

</td></tr><tr><td>

headers

</td><td>

Object

</td><td>

Headers for the message, defined as key-value pairs. ```
"headers": {
  "<key>": "<value>"
}
```

For example, `var headers = { "origin": "sn_business_rule" };` -   `key`: String. Name of the header.
-   `value`: String. Value of the header.

</td></tr><tr><td>

schemaID

</td><td>

String

</td><td>

Sys\_id of the schema record.Required if you're using a schema to convert plain-text messages to Avro messages and back. Schemas are stored in the Stream Connect Schemas \[stream\_connect\_schema\] table. For more information, see [Schema management in Stream Connect](https://raw.githubusercontent.com/ServiceNow/ServiceNowDocs/australia/markdown/integrate-applications/schema-management.md).

</td></tr></tbody>
</table><table id="table_wn5_c3f_nvb" class="returns"><thead><tr><th>

Object property

</th><th>

Description

</th></tr></thead><tbody><tr><td>

delivery

</td><td>

Kafka producer delivery. Reflects the value set for the **isSync** parameter.Possible values:

-   async - Asynchronous delivery
-   sync - Synchronous delivery

Data type: String

</td></tr><tr><td>

offset

</td><td>

The offset of the message in the partition of the topic in Hermes Kafka. This value is only returned for synchronous delivery.Data type: Number

</td></tr><tr><td>

partition

</td><td>

Partition of the topic in which the message is stored. This value is only returned for synchronous delivery.Data type: Number

</td></tr></tbody>
</table>### Asynchronous delivery

This example shows how to send changed incident information to the Kafka topic with a sys\_id of 75135aa2ff0311105cf343d0653bf155, using a schema with a sys\_id of f9d083f3ff610210ef7343d3653bf12e.

```
var message = {
  'number': current.number.toString(),
  'short_description': current.short_description.toString(),
  'caller_id': current.caller_id.getDisplayValue(),
  'priority': current.priority.toString(),
  'state': current.state.toString()
};

var headers = {
    'origin': 'sn_business_rule'
};

var producer = new sn_ih_kafka.ProducerV2();
producer.send('75135aa2ff0311105cf343d0653bf155', gs.generateGUID(), JSON.stringify(message), false, headers, 'f9d083f3ff610210ef7343d3653bf12e');

```

### Synchronous delivery

This example shows how get the return values of a Kafka message.

```
var message = "Defect fix";
 
var producer = new sn_ih_kafka.ProducerV2();
 
var response = producer.send('63820c0e1b492210dcff64e5604bcb93', gs.generateGUID(), JSON.stringify(message), true, null);
gs.log("Partition was "+response.partition);
gs.log("Offset was :"+response.offset);
gs.log("Delivery was :"+response.delivery);
```

Output:

```
*** Script: Partition was 1
*** Script: Offset was :258072
*** Script: Delivery was :sync
```