@hylink/node-red-kafka-client
v0.2.6
Published
Node-RED Kafka Consumer and Producer
Downloads
95
Maintainers
Readme
@hylink/node-red-kafka-client
This node can be used in order to produce and consume messages to Kafka. It is highly depends on 'kafka-node' library. Consists three nodes.
- kafka-broker
- kafka-producer
- karka-consumer
Note: This library add sasl/plain supports base on node-red-contrib-kafka-client project
Input Parameters
kafka-broker
Name (Optional)
Name wanted to be shown in Node
Hosts
Host names comma delimited (Multiple host is provided)
Use TLS
Check if tls security is required for Kafka Cluster
CA Certs (Optional)
CA Root certificate path defined in Kafka Cluster
Client Cert (Optional)
Client cert path created by openssl derived from Private Key (pem)
Private Key (Optional)
Private Key path created by openssl (pem)
Passphare (Optional)
Passphrase of created private Key
Self Sign
Check if want to be allowed untrusted certificates
Use SASL
Check if SASL security is required for Kafka Cluster
SASL Username (Optional)
SASL Username
SASL Password (Optional)
SASL Password
kafka-producer
Name (Optional)
Name wanted to be shown in NodeRename your node
Broker
Broker which is wanted to be connect
Topic
Topic name of selected broker which is wanted to be consume
Require Ack
Default value is 1. 0 can be past if Acknowledge is not required.
Ack Timeout
Timeout of acknowledge response.
Attiributes
Can be selected if compression is important
kafka-consumer
Name (Optional)
Name wanted to be shown in NodeRename your node
Broker
Broker which is wanted to be connect
Topic
Topic name of selected broker which is wanted to be consume
From Offset
'latest', 'none' or 'earliest' options can be selected
Out of Range Offset
'latest', 'none' or 'earliest' options can be selected
Installation
npm install node-red-contrib-kafka-client
Usage
- Example JSON here
{"topic":"TOPIC_NAME","value":"DENEME","offset":16638,"partition":0,"highWaterOffset":16639,"key":null,"timestamp":"2020-08-19T08:58:27.866Z"}