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

​
Basic Parameters

ParameterDescription
AddressThe Kafka broker address to produce messages to.
Topic NameThe name of the target Kafka topic where messages will be produced. Can be obtained by using the Get Broker Metadata action.
PartitionThe partition number where messages will be produced (zero-based). Can be obtained by using the Get Broker Metadata action.
MessagesA JSON array of message records to produce in a single batch. See format details below.
Required AcknowledgementsThe 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

ParameterDescription
Message VersionThe message version to use. When omitted, the latest message version will be used.
Transactional IDA transactional ID to use for transactional producers. Leave empty for non-transactional producers.
CompressionA compression algorithm used to compress the messages. Options: Gzip, Snappy, Lz4, Zstd.

​
Example Output

Messages produced successfully!