Message Queue Nodes

Publish messages to Kafka topics and RabbitMQ exchanges in Axellero workflows.

Overview

Message queue nodes support message publishing to external message brokers. Kafka provides topic-based publishing with SASL authentication, while RabbitMQ supports exchange and queue publishing with AMQP authentication.

Current Implementation

These nodes currently support message publishing only. Message consumption and queue management operations are not supported.

Kafka Node

Publish messages to Kafka topics with SASL authentication

RabbitMQ Node

Publish messages to RabbitMQ exchanges and queues with AMQP

Available Protocols

Protocol	Authentication	Publishing Support	Current Capabilities
Kafka	SASL/PLAIN	Topic publishing	Message publishing only
RabbitMQ	AMQP	Exchange/Queue publishing	Message publishing only

Operations

Publish: Send messages to topics, exchanges, or queues

Not Yet Implemented

Message consumption, subscriptions, queue management, and trigger functionality are not currently supported.

Workflow Integration

Message queue nodes support dynamic content construction using workflow context:

{
  "topic": "{{ctx.workspace_slug}}-events",
  "key": "{{ctx.vars.eventType}}",
  "value": "{{ctx.nodes.eventFormatter.outputs.eventData}}"
}

Use Cases

Event Publishing: Publish workflow events to external systems
Data Export: Send processed data to downstream consumers
Notification Distribution: Publish notification events to processing queues
Audit Logging: Send audit events to centralized logging systems

Getting Started

Choose Protocol: Select Kafka for topic-based or RabbitMQ for exchange-based messaging
Configure Connection: Set up broker details and authentication credentials
Define Publishing: Specify topics, exchanges, or queues for message delivery
Test Integration: Validate message publishing and delivery

Message Queues