Confluent Platform and Node-RED Integration

Overview

Node-RED and Confluent Platform complement each other in Industrial IoT architectures. Node-RED provides visual, low-code integration with industrial protocols (Modbus, OPC-UA, MQTT), while Confluent Platform handles enterprise-grade event streaming, persistence, and distribution.

Integration Patterns

Pattern 1: Node-RED as Kafka Producer

PLC/OPC-UA → Node-RED → Kafka topic → Confluent Platform → Analytics/Storage

• Node-RED reads from industrial sources
• Formats and publishes to Kafka topics
• Confluent handles distribution and processing

Pattern 2: Node-RED as Kafka Consumer

Sensor data → Confluent Platform → Kafka topic → Node-RED → Dashboard/Alert

• Confluent ingests high-volume sensor data
• Node-RED consumes filtered/relevant events
• Visual flows trigger actions and notifications

Pattern 3: Bidirectional Gateway

Shop floor ←→ Node-RED ←→ Confluent Platform ←→ Enterprise systems

• Node-RED bridges OT protocols to IT systems
• Confluent provides the reliable message backbone

Implementation

Node-RED Kafka Nodes: Use node-red-contrib-kafka-manager or similar

• Configure with Confluent broker endpoints
• Support SASL/SSL authentication
• Handle schema registry for Avro/Protobuf

When to Use This Combo

Manufacturing Example

A packaging line uses Node-RED to read OPC-UA tags from PLCs, formats the data, and publishes to a "production.metrics" Kafka topic. Confluent Platform distributes these events to:

• ksqlDB for real-time OEE calculation
• InfluxDB for historical trending
• ERP system via Kafka Connect