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

Name wanted to be shown in Node

Host names comma delimited (Multiple host is provided)

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 security is required for Kafka Cluster

SASL Username

SASL Password

Name wanted to be shown in NodeRename your node

Broker which is wanted to be connect

Topic name of selected broker which is wanted to be consume

Default value is 1. 0 can be past if Acknowledge is not required.

Timeout of acknowledge response.

Can be selected if compression is important

Name wanted to be shown in NodeRename your node

Broker which is wanted to be connect

Topic name of selected broker which is wanted to be consume

'latest', 'none' or 'earliest' options can be selected

'latest', 'none' or 'earliest' options can be selected

npm install node-red-contrib-kafka-client

1. Example JSON here

{"topic":"TOPIC_NAME","value":"DENEME","offset":16638,"partition":0,"highWaterOffset":16639,"key":null,"timestamp":"2020-08-19T08:58:27.866Z"}