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

Node Info

Version: 0.0.6
Updated 1 year, 1 month ago
License: MIT

Downloads

11 in the last day
59 in the last week
205 in the last month

Nodes

  • confluent in
  • confluent out
  • rest-proxy
  • confluent metadata

Keywords

  • node-red
  • kafka
  • confluent
  • kafka-rest

Maintainers

  • hjespers