Produce Messages - BlinkOps Documentation

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

Basic Parameters

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).

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:

[
  {
    "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

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`.

Example Output

Messages produced successfully!

​Basic Parameters

​Messages Format

​Advanced Parameters

​Example Output

Basic Parameters

Messages Format

Advanced Parameters

Example Output