Kafka Extended icon

Kafka Extended

Send messages to Kafka with compression and Schema Registry support

Kafka Extended

AI-generated

Summary

Send a message to a Kafka topic, optionally using Schema Registry, compression, headers, and acknowledgment settings.

Inputs

  • topic (required) — Kafka topic to produce to (string, supports expressions).
  • message (required) — Message value to send (string, supports expressions). If Schema Registry is enabled for producing, must be valid JSON.
  • key — Message key used for partitioning (string, optional).
  • compression — Compression codec: None (0), GZIP (1), Snappy (2), LZ4 (3), ZSTD (4). Defaults to None (0).
  • options.acks — Number of required acknowledgements: None (0), Leader (1), All ISR (-1). Defaults to All ISR (-1).
  • options.headers — Key‑value message headers (fixed collection, multiple values allowed).
  • options.schemaRecordName — Record name used by Record Name Strategy or Topic Record Name Strategy (string). Shown when Schema Registry is enabled and strategy is record or topicrecord.
  • options.schemaSubjectStrategy — Strategy to resolve Schema Registry subject: Topic Name Strategy (topic), Record Name Strategy (record), Topic Record Name Strategy (topicrecord). Defaults to topic. Shown when Schema Registry is enabled.
  • options.timeout — Producer send timeout in milliseconds. Defaults to 30000.
  • options.useSchemaRegistryForProducing — Whether to encode the message value using Schema Registry (boolean). Requires Schema Registry configured in credentials. Defaults to false.

Output shape

array of objects, one per input item

Each output object contains a json field with metadata about the produced record and a pairedItem linking back to the input index. On error, if continueOnFail is enabled, the json field contains an error property with the error message.

Examples

Example 1: Produce a plain text message with compression

topic='events', message='Hello', compression='GZIP'

Example 2: Produce a JSON message using Schema Registry with Topic Name Strategy

topic='users', message='{$json}', useSchemaRegistryForProducing=true

Links

Discussion