This node can be used in order to produce and consume messages to Kafka. It is highly depends on 'kafkajs' library. Consists three nodes.
This node is an advanced version to https://github.com/emrebekar/node-red-contrib-kafkajs
- kafka-client
- kafka-producer
- kafka-consumer
The enhancements in this version is to have
- Change in Consumer with a configurable PartitionId which access an integer or an environment variable.
- Change in Producer with an option to enter an environement variable.
Further details can be found in following pages:
- Client Configuration: https://kafka.js.org/docs/configuration
- Consuming Messages: https://kafka.js.org/docs/consuming
- Producing Messages: https://kafka.js.org/docs/producing
Name wanted to be shown in Node
Brokers comma delimited (Multiple host is provided)
ID of client to be connected to Kafka Cluster
Request timeout of Kafka Client
Connection timeout of Kafka Client
Log level of Kafka Cient
Check if tls security is required for Kafka Cluster
CA Root certificate path defined in Kafka Cluster
Client cert path created by openssl derived from Private Key (pem)
Private Key path created by openssl (pem)
Passphrase of created private Key
Check if want to be allowed untrusted certificates
Check if sasl auth is required for Kafka Cluster
Username in order to connect to Kafka Cluster
Password in order to connect to Kafka Cluster
Activate SSL Connection
Advanced Retry Options of Kafka Client
Name wanted to be shown on your node
Client which is wanted to be connect
Topic name of selected broker which is wanted to be consume
Advanced options of Producer
Some parameters can be send over kafka pipe.
Notice: Parameters in Producer Node have to be null
msg.key msg.topic msg.partition msg.headers
Name wanted to be shown on your node
Client which is wanted to be connect
Group ID of consumer. If it is null, custom uuid will be generated for every connection
Topic name of selected broker which is wanted to be consume
Advanced options of Consumer
npm install node-red-contrib-kafkajs
