{"_id":"@clevabit/node-red-contrib-kafkajs","name":"@clevabit/node-red-contrib-kafkajs","dist-tags":{"latest":"0.0.6"},"versions":{"0.0.6":{"name":"@clevabit/node-red-contrib-kafkajs","node-red":{"nodes":{"kafka-consumer":"./js/kafka-consumer.js","kafka-producer":"./js/kafka-producer.js","kafka-broker":"./js/kafka-client.js"}},"dependencies":{"kafkajs":"^1.12.0","uuid":"^8.3.2"},"homepage":"https://github.com/emrebekar/node-red-contrib-kafkajs#readme","version":"0.0.6","license":"Apache 2.0","keywords":["kafka","kafkajs","node-red"],"gitHead":"40eacdf30877c7070dce120fd72a68d5ecf1578b","description":"This node can be used in order to produce and consume messages to Kafka. It is highly depends on 'kafkajs' library. Consists three nodes.","_id":"@clevabit/node-red-contrib-kafkajs@0.0.6","_nodeVersion":"14.17.0","_npmVersion":"6.14.13","dist":{"integrity":"sha512-iqW3U8AstNhauZF0yd3Ldwq+3/aQfATPcMRcS5d+w+EtoZL1mHhjhAjMUV4yw066pK/OWs5W6omk9XjrhtmnnQ==","shasum":"2a8b7fe40061197c03717f89ff52c53e4fcb0ada","tarball":"https://registry.npmjs.org/@clevabit/node-red-contrib-kafkajs/-/node-red-contrib-kafkajs-0.0.6.tgz","fileCount":14,"unpackedSize":106603,"signatures":[{"keyid":"SHA256:jl3bwswu80PjjokCgh0o2w5c2U4LhQAE57gj9cz1kzA","sig":"MEQCICilGOV5Pa06ODyMHhoeZuh5uxENgZjj3M9/Mw+WHIusAiAbgezbVFMFrO9p4lKDvHTzKE5rzh8x/e+SysOQbdN6aw=="}],"npm-signature":"-----BEGIN PGP SIGNATURE-----\r\nVersion: OpenPGP.js v4.10.10\r\nComment: https://openpgpjs.org\r\n\r\nwsFzBAEBCAAGBQJighSQACEJED1NWxICdlZqFiEECWMYAoorWMhJKdjhPU1b\r\nEgJ2VmoaVg/9F2BJPjmYk7l2aYmVGWIbIAJqcxzlkd6knUiWORQcWxQLRWLg\r\nhcTg5NS/qGzupU0gEQ+sMRCqZi6ydMySAaVDwPNas8oRl+g8t1zHrzRVCvlW\r\n4z/CAKRf/SDxhnHBlxqyOKuXRG+g23iHeei/AuCN/yJq8Jrk1G2Y9NqZKEyB\r\nCY0lO81NWtKe6KsYmpjRmv8mW+8+lo7BTnO1SO2B7P/aZDarpq8C5zH1AfpU\r\naRE7L6OLdvS/jASv/pXYdYh2+UdObRBBf4o3rG3n84VqEBH6zwu5z9FXOZED\r\nVcA6srUQeHWwqWc/YijjDDF65w6f5j0PAdyaZ37Kgq7VcS9Nt5kDl4bR0rhq\r\nstrrEcTCrTWA47rodnMgxKl1X5eksWQe6x2HWUst5RXFoRMcq12m9/YdxXDa\r\nohHWnS2xpq7MPvt7TIJpMm9CD9KYug1FvzQjMDzrgtubEFM9LZoxXvPCihq/\r\neigS7n4xA/pOt5eC5BfijA0k0FC8ZsR0ru4jBIoiik4kcemMYtkzRTHou5G7\r\n0iFhylffQLSDV3ZUrAVr33idsxS25R6qg+AeqZZ4Ek45tl1fznt8330wa6PI\r\nqdOwK07qg79aAnlL8Qezye0Fqch0dXq/csMYoBGiUKFb6h8yJDXfbe+jI5TW\r\niG1v+HHOnB/J+pOI61yAaBjw/kNM1lY39sw=\r\n=LjkH\r\n-----END PGP SIGNATURE-----\r\n"},"_npmUser":{"name":"noctarius","email":"cengelbert@clevabit.com"},"directories":{},"maintainers":[{"name":"noctarius","email":"cengelbert@clevabit.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages","tmp":"tmp/node-red-contrib-kafkajs_0.0.6_1652692112101_0.43455721235504696"},"_hasShrinkwrap":false}},"time":{"created":"2022-05-16T09:08:31.951Z","0.0.6":"2022-05-16T09:08:32.233Z","modified":"2022-05-16T09:08:32.365Z"},"maintainers":[{"name":"noctarius","email":"cengelbert@clevabit.com"}],"description":"This node can be used in order to produce and consume messages to Kafka. It is highly depends on 'kafkajs' library. Consists three nodes.","homepage":"https://github.com/emrebekar/node-red-contrib-kafkajs#readme","keywords":["kafka","kafkajs","node-red"],"license":"Apache 2.0","readme":"# node-red-contrib-kafkajs\n\nThis node can be used in order to produce and consume messages to Kafka. It is highly depends on 'kafkajs' library. Consists three nodes.\n\nThis node is an advanced alternative to https://github.com/emrebekar/node-red-contrib-kafka-client\n\n- kafka-client\n- kafka-producer\n- kafka-consumer\n\nFurther details can be found in following pages:\n\n- Client Configuration: https://kafka.js.org/docs/configuration\n- Consuming Messages: https://kafka.js.org/docs/consuming\n- Producing Messages: https://kafka.js.org/docs/producing\n\n## Input Parameters\n### kafkajs-client\n#### Name (Optional)\nName wanted to be shown in Node\n#### Brokers\nBrokers comma delimited (Multiple host is provided)\n#### Client ID\nID of client to be connected to Kafka Cluster\n#### Request Timeout\nRequest timeout of Kafka Client\n#### Connection Timeout\nConnection timeout of Kafka Client\n#### Log Level\nLog level of Kafka Cient\n\n#### Authentication\n#### TLS\nCheck if tls security is required for Kafka Cluster\n#### CA Certs (Optional)\nCA Root certificate path defined in Kafka Cluster\n#### Client Cert (Optional)\nClient cert path created by openssl derived from Private Key (pem)\n#### Private Key (Optional)\nPrivate Key path created by openssl (pem)\n#### Passphare (Optional)\nPassphrase of created private Key\n#### Self Sign\nCheck if want to be allowed untrusted certificates\n\n#### SASL/PLAIN\nCheck if sasl auth is required for Kafka Cluster\n#### Username\nUsername in order to connect to Kafka Cluster\n#### Password\nPassword in order to connect to Kafka Cluster\n#### Use SSL\nActivate SSL Connection\n\n#### Advanced Retry Options\nAdvanced Retry Options of Kafka Client\n\n### kafkajs-producer\n#### Name (Optional)\nName wanted to be shown on your node\n#### Client\nClient which is wanted to be connect\n#### Topic\nTopic name of selected broker which is wanted to be consume\n#### Advanced Options\nAdvanced options of Producer\n\nSome parameters can be send over kafka pipe.\n\nNotice: Parameters in Producer Node have to be null\n\nmsg.key\nmsg.topic\nmsg.partition\nmsg.headers\n\n### kafkajs-consumer\n#### Name (Optional)\nName wanted to be shown on your node\n#### Client\nClient which is wanted to be connect\n#### Group ID\nGroup ID of consumer. If it is null, custom uuid will be generated for every connection\n#### Topic\nTopic name of selected broker which is wanted to be consume\n#### Advanced Options\nAdvanced options of Consumer\n\n## Installation\n```\nnpm install node-red-contrib-kafkajs\n```\n## Screenshots\n\n![kafkajs-client](https://raw.githubusercontent.com/emrebekar/node-red-contrib-kafkajs/master/images/kafka-client.PNG)\n\n![kafkajs-consumer](https://raw.githubusercontent.com/emrebekar/node-red-contrib-kafkajs/master/images/kafka-consumer.PNG)\n\n![kafkajs-producer](https://raw.githubusercontent.com/emrebekar/node-red-contrib-kafkajs/master/images/kafka-producer.PNG)\n","readmeFilename":"README.md"}