FlowDSL Node Catalog
Kafka Produce
Publish a raw message to a Kafka topic via the configured event bus.
Overview
| Property | Value |
|---|---|
| Node ID | redelay/kafka-produce |
| Kind | action |
| Module | events-flowdsl |
| Repo | go-flowdsl |
| Module ref | events |
| Handler | github.com/redelay/go-flowdsl/nodes.KafkaProduce |
| Icon | lucide:plug-zap |
| Color | #1f2937 |
| Tags | kafka, publish, producer |
Description
Wraps the current EventBus in a topic-bound publish. The packet's
payload path is JSON-encoded into EventMessage.Payload; headers are
copied from the configured headersPath.
Outputs
out— (no description)
Settings
| Property | Type | Required | Default | UI Group | Description |
|---|---|---|---|---|---|
action | string | — | — | Envelope | |
entityType | string | — | — | Envelope | |
headersPath | string | — | — | Envelope | |
payloadPath | string | yes | — | Data | |
topic | string | yes | — | Target |
Example
yaml
# Use this node in a flow:
nodes:
- id: my_step
name: My Step
kind: action
action_ref: redelay/kafka-produce
config:
action: "value"
entityType: "value"
headersPath: some.packet.path
payloadPath: some.packet.path
topic: "value"