#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