> ## Documentation Index
> Fetch the complete documentation index at: https://docs.blinkops.com/llms.txt
> Use this file to discover all available pages before exploring further.

# Produce Messages

Produce one or more messages to a specific Kafka topic and partition.

## Basic Parameters

<div className="integrations-table">
  | Parameter                 | Description                                                                                                                                                                                                                                                                 |
  | ------------------------- | --------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- |
  | Address                   | The Kafka broker address to produce messages to.                                                                                                                                                                                                                            |
  | Topic Name                | The name of the target Kafka topic where messages will be produced. Can be obtained by using the `Get Broker Metadata` action.                                                                                                                                              |
  | Partition                 | The partition number where messages will be produced (zero-based). Can be obtained by using the `Get Broker Metadata` action.                                                                                                                                               |
  | Messages                  | A JSON array of message records to produce in a single batch. See format details below.                                                                                                                                                                                     |
  | Required Acknowledgements | The acknowledgment requirement for message production. Options: `Require None` (producer doesn't wait for any acknowledgment), `Require One` (producer waits for the leader broker to acknowledge), `Require All` (producer waits for all in-sync replicas to acknowledge). |
</div>

### Messages Format

Each message record in the array supports the following properties:

* `key`: String key for the message.
* `value`: String value for the message.
* `offset`: (optional) Integer offset for the message (defaults to auto-assignment if not specified).
* `headers`: (optional) Array of header objects with `key` and `value` string properties for custom metadata.
* `time`: (optional) ISO 8601 timestamp string for message timestamp.

**Example**:

```json theme={"dark"}
[
  {
    "key": "order-123",
    "value": "{\"orderId\":123,\"amount\":99.99}",
    "offset": 0,
    "headers": [
      {
        "key": "source",
        "value": "api"
      },
      {
        "key": "version",
        "value": "1.0"
      }
    ],
    "time": "2025-11-18T10:30:00Z"
  },
  {
    "key": "order-124",
    "value": "{\"orderId\":124,\"amount\":149.99}"
  }
]
```

## Advanced Parameters

<div className="integrations-table">
  | Parameter        | Description                                                                                         |
  | ---------------- | --------------------------------------------------------------------------------------------------- |
  | Message Version  | The message version to use. When omitted, the latest message version will be used.                  |
  | Transactional ID | A transactional ID to use for transactional producers. Leave empty for non-transactional producers. |
  | Compression      | A compression algorithm used to compress the messages. Options: `Gzip`, `Snappy`, `Lz4`, `Zstd`.    |
</div>

## Example Output

```json theme={"dark"}
Messages produced successfully!
```