---
title: "system.kafka.sendRecord"
description: "Sends a record to a specified topic."
---

# system.kafka.sendRecord

> Sends a record to a specified topic.

This function is used in **Python Scripting**.

## Description
Sends a record to a specified topic, with further sends blocked until a response is received. This is considerably slower than [system.kafka.sendRecordAsync](appendix\scripting-functions\system-kafka\system-kafka-sendRecordAsync.md), and should only be used if a metadata response is required.

## Client Permission Restrictions
This scripting function has no [Client Permission](ignition-modules\vision\vision-project-properties\vision-project-properties.md#vision-permissions-properties) restrictions.

## Syntax
`system.kafka.sendRecord(connector, topic, key, value, [partition], [timestamp], [headerKeys], [headerValues], [options])`

### Parameters

| Type | Parameter | Description |
|---|---|---|
| String | `connector` | The name of the Kafka connector. |
| String | `topic` | The name of the Kafka topic. |
| String | `key` | The Kafka record key, used in identifying the record. |
| String | `value` | The Kafka record value you want to send. |
| Integer | `partition` | The partition to target. Optional. |
| Long | `timestamp` | The record timestamp, in milliseconds. Optional. |
| List | `headerKeys` | The header keys for the record. Optional. |
| List | `headerValues` | The header values for the record. Optional. |
| Dictionary | `options` | Custom options specific to the producer, with key value string pairs. Optional. |
    
### Returns
**PyDictionary** - A PyDictionary representing metadata response in key value pairs. The metadata contains keys for:
* topic
* partition
* offset
* timestamp
    
### Scope
Gateway

## Code Examples
```python title="Example #1"
# Sends a record to the specified topic, with further sends blocked until a response is received.
system.kafka.sendRecord("MyKafkaConnector", "MyKafkaTopic", "k2", "25")
```