node-red-contrib-confluent 0.0.6

Node-Red module for Apache Kafka publish/subscribe using the Confluent REST Proxy

npm install node-red-contrib-confluent

#node-red-contrib-confluent

Node-RED (http://nodered.org) nodes for publish/subscribe messaging with Apache Kafka using HTTP(S) calls to the Confluent REST Proxy (https://github.com/confluentinc/kafka-rest).

Works with Apache Kafka 0.9 and 0.10 including Confluent Open Source and Confluent Enterprise distributions (versions 2.0 and 3.0).

#Install

Run the following command in the root directory of your Node-RED install

npm install node-red-contrib-confluent

Start node-red as normal or use the -v flag for more verbose debugging

node-red -v

Point your browser to http://localhost:1880

You should see orange confluent input and output nodes in the pallet on the left side of the screen.

• input
• output

Drag either confluent node to the canvas and double click to configure the topic, key, partition, rest-proxy, clientID and groupID.

Click on the pencil icon to the right of the rest-proxy selection box to configure a rest-proxy URL if one does not already exist.

Publish and subscribe just as you would with the mqtt node with some small differences namely:

• topics should not contain "/" or "." characters
• kafka wildcard/regex subscriptions are not yet fully tested
• ensure you have unique Group IDs configured unless you want multiple consumers to be in a Kafka consumer group

#Author

Hans Jespersen, https://github.com/hjespers

#Feedback and Support

For more information, feedback, or support see https://github.com/hjespers/node-red-contrib-confluent/issues