Gathering detailed insights and metrics for node-red-contrib-kafka-manager
Gathering detailed insights and metrics for node-red-contrib-kafka-manager
Installations
npm install node-red-contrib-kafka-managerDeveloper Guide
BETA
Typescript
No
Module System
N/A
Node Version
12.22.12
NPM Version
6.14.16
Releases
14
see hist
v0.6.2
Updated on Jan 22, 2023
v0.6.1
v0.6.1
Updated on Jan 22, 2023
Changed compression, added dead letter q
v0.6.0
Updated on Jan 21, 2023
minor fix to remove error and latest security patches
v5.0.1
Updated on Feb 18, 2022
Generic consumer topics. Add/remove topic from consumer
v5.0.0
Updated on Nov 16, 2020
Add json conversion option on message
v0.4.3
Updated on Nov 07, 2020
Languages
2
JavaScript
HTML
JavaScript (75.31%)
HTML (24.69%)
Developer
peterprib
Download Statistics
Total Downloads
0
Last Day
0
Last Week
0
Last Month
0
Last Year
0
GitHub Statistics
GPL-3.0 License
23 Stars
116 Commits
10 Forks
6 Watchers
3 Branches
5 Contributors
Updated on Feb 26, 2025
Maintainers
1
Package Meta Information
Latest Version
0.6.2
Package Id
node-red-contrib-kafka-manager@0.6.2
Unpacked Size
1.13 MB
Size
492.30 kB
File Count
59
NPM Version
6.14.16
Node Version
12.22.12
Published on
Jan 22, 2023
Total Downloads
Cumulative downloads
Total Downloads
NaN
Last Day
0%
NaN
Compared to previous day
Last Week
0%
NaN
Compared to previous week
Last Month
0%
NaN
Compared to previous month
Last Year
0%
NaN
Compared to previous year
Weekly Downloads
Monthly Downloads
Yearly Downloads
node-red-contrib-kafka-manager
Node Red for working with apache kafka, a streaming product. First initial release using kafka-node .
- Kafka Broker
- Kafka Admin
- Kafka Commit
- Kafka Consumer
- Kafka ConsumerGroup
- Kafka Offset
- Kafka Producer
- Kafka Rollback
Has a test GUI which allows topics to be added.
Special features:
- Generic topic(s) for a consumer using regex which dynamically adds new topics as they are defined
- For consumer add/remove topics (not persisted)
- Convert "/" to "." to assist with interfaces to other queueing technologies
Note: all nodes run in debug mode for 111 messages then turns off.
Kafka Broker
Defines the client interface to kafka. One can add process.env for hosts with
process.env.atesthosts='[{"host":"atesthost1","port":1234},{"host":"atesthost2","port":4321}]';
in settings.js
Kafka Admin
Provide the ability to process administration tasks such as create and list topic.
Following topics commnads or via GUI allowed:
- describeCluster
- describeDelegationToken
- describeReplicaLogDirs
- listConsumerGroups
- listGroups
- listTopics
Plus following topics commands allowed where paramaters are payload:
- alterConfigs, alterReplicaLogDirs, createAcls,createDelegationToke
- createPartitions, createTopics, deleteAcls, deleteConsumerGroups, deleteRecords
- deleteTopics, describeAcls, describeConsumerGroups, describeGroups, describeLogDirs, describeTopics * electPreferredLeaders, expireDelegationToken, incrementalAlterConfigs, listConsumerGroupOffsets, renewDelegationToken
Kafka Commit
If msg._kafka exists and the consumer associated with the message is not on autocommit, it issues commit for the consumer that had produced the message. Sends to OK or Error port depending on state. Note, as Kakfa keeps giving messages to consumer regardless if commit being outstanding, the commit may commit many in-flight messages. Haven't identified a method of readily preventing this behavour without complications.
Kafka Consumer
Consumer of topic messages in kafka which are generated into node-red message. Provides types of base and high level. If wildcard selected then topics are regex patterns which are dynamically made active (or removed) when available. A check is performed once every minute for chanaes to topics.
Kafka Consumer Group
Consumer of topic messages in kafka which are generated into node-red message.
Kafka Offset
Get various offsets from Kafka. Which type are set via msg.action or msg.topic. msg.payload states the types of options.
Kafka Producer
Converts a node-red message into a kafka messages. Provides types of base and high level.
Kafka Rollback
If msg._kafka exists and the consumer associated with the message is not on autocommit, it closes the consumer. This effectively rolls back the message in Kafka plus ensures the message cannot be automatically handed to the the consumer. It is expected that the message or problem is fixed and the consumer opened again for processing.
Simple Web Admin Panel
Simple Web page monitor and admin panel
Install
Run the following command in the root directory of your Node-RED install or via GUI install
npm install node-red-contrib-kafka-manager
Tests
Test/example flow in test/generalTest.json
Version
0.6.1 Major change in compression and add deadletter q
0.5.0 add consumer wildcard topics + topics / to . along with fix on to/from/json
Author
No vulnerabilities found.
Reason
no dangerous workflow patterns detected
Reason
no binaries found in the repo
Reason
license file detected
Details
- Info: project has a license file: LICENSE:0
- Info: FSF or OSI recognized license: GNU General Public License v3.0: LICENSE:0
Reason
dependency not pinned by hash detected -- score normalized to 3
Details
- Warn: GitHub-owned GitHubAction not pinned by hash: .github/workflows/npm-publish.yml:14: update your workflow using https://app.stepsecurity.io/secureworkflow/peterprib/node-red-contrib-kafka-manager/npm-publish.yml/master?enable=pin
- Warn: GitHub-owned GitHubAction not pinned by hash: .github/workflows/npm-publish.yml:15: update your workflow using https://app.stepsecurity.io/secureworkflow/peterprib/node-red-contrib-kafka-manager/npm-publish.yml/master?enable=pin
- Warn: GitHub-owned GitHubAction not pinned by hash: .github/workflows/npm-publish.yml:25: update your workflow using https://app.stepsecurity.io/secureworkflow/peterprib/node-red-contrib-kafka-manager/npm-publish.yml/master?enable=pin
- Warn: GitHub-owned GitHubAction not pinned by hash: .github/workflows/npm-publish.yml:26: update your workflow using https://app.stepsecurity.io/secureworkflow/peterprib/node-red-contrib-kafka-manager/npm-publish.yml/master?enable=pin
- Info: 0 out of 4 GitHub-owned GitHubAction dependencies pinned
- Info: 2 out of 2 npmCommand dependencies pinned
Reason
0 commit(s) and 0 issue activity found in the last 90 days -- score normalized to 0
Reason
Found 0/15 approved changesets -- score normalized to 0
Reason
detected GitHub workflow tokens with excessive permissions
Details
- Warn: no topLevel permission defined: .github/workflows/npm-publish.yml:1
- Info: no jobLevel write permissions found
Reason
no effort to earn an OpenSSF best practices badge detected
Reason
security policy file not detected
Details
- Warn: no security policy file detected
- Warn: no security file to analyze
- Warn: no security file to analyze
- Warn: no security file to analyze
Reason
project is not fuzzed
Details
- Warn: no fuzzer integrations found
Reason
branch protection not enabled on development/release branches
Details
- Warn: branch protection not enabled for branch 'master'
Reason
SAST tool is not run on all commits -- score normalized to 0
Details
- Warn: 0 commits out of 15 are checked with a SAST tool
Reason
28 existing vulnerabilities detected
Details
- Warn: Project is vulnerable to: GHSA-x3cc-x39p-42qx
- Warn: Project is vulnerable to: GHSA-4r6h-8v6p-xvw6
- Warn: Project is vulnerable to: GHSA-5pgg-2g8v-p4x9
- Warn: Project is vulnerable to: GHSA-968p-4wvh-cqc8
- Warn: Project is vulnerable to: GHSA-8hc4-vh64-cxmj
- Warn: Project is vulnerable to: GHSA-jr5f-v2jv-69x6
- Warn: Project is vulnerable to: GHSA-qwcr-r2fm-qrc7
- Warn: Project is vulnerable to: GHSA-v6h2-p8h4-qcjw
- Warn: Project is vulnerable to: GHSA-grv7-fg5c-xmjg
- Warn: Project is vulnerable to: GHSA-pxg6-pf52-xh8x
- Warn: Project is vulnerable to: GHSA-rv95-896h-c2vc
- Warn: Project is vulnerable to: GHSA-qw6h-vgh9-j6wx
- Warn: Project is vulnerable to: GHSA-cxjh-pqwp-8mfp
- Warn: Project is vulnerable to: GHSA-75v8-2h7p-7m2m
- Warn: Project is vulnerable to: GHSA-fqg8-vfv7-8fj8
- Warn: Project is vulnerable to: GHSA-44fp-w29j-9vj5
- Warn: Project is vulnerable to: GHSA-4pg4-qvpc-4q3h
- Warn: Project is vulnerable to: GHSA-g5hg-p3ph-g8qg
- Warn: Project is vulnerable to: GHSA-mwcw-c2x4-8c55
- Warn: Project is vulnerable to: GHSA-9wv6-86v2-598j
- Warn: Project is vulnerable to: GHSA-rhx6-c78j-4q9w
- Warn: Project is vulnerable to: GHSA-m6fv-jmcg-4jfg
- Warn: Project is vulnerable to: GHSA-76p7-773f-r4q5
- Warn: Project is vulnerable to: GHSA-cm22-4g7w-348p
- Warn: Project is vulnerable to: GHSA-f5x3-32g6-xq36
- Warn: Project is vulnerable to: GHSA-pq67-2wwv-3xjx
- Warn: Project is vulnerable to: GHSA-8cj5-5rvv-wf4v
- Warn: Project is vulnerable to: GHSA-3h5v-q93c-6h6q
Score
2.7
/10
Last Scanned on 2025-07-07
The Open Source Security Foundation is a cross-industry collaboration to improve the security of open source software (OSS). The Scorecard provides security health metrics for open source projects.
Learn More