MCP, MCP server
Agentic Engineering For Apache Kafka
Lenses Kafka agent skills (topic audit, consumer lag, perf review, schema, security, connectors, DLQ, python client scaffold) powered by the Lenses MCP server
Compatibility: Not stated.
Grade B
Minor issues only, no Medium or High. Worth a quick look at the findings below before installing.
Not a guarantee. A hygiene check of the source at the commit shown, not a security audit.
Rescanned at commit 8cee08b1681c, unchanged since the check below.
NETWORK_NO_FIXED_HOST SECRETS_PATH_DOTENV OBFUSCATION_ENCODED_BLOB SECRETS_ENV_READ
Why this grade
- NETWORK_NO_FIXED_HOST Low
Makes a network call whose host is not written as a fixed address.
skills/kafka-python-client/references/common-template.py, line 143
resp = requests.get(url, auth=auth, timeout=timeout) - SECRETS_PATH_DOTENV Low
Mentions a .env file.
skills/kafka-python-client/SKILL.md, line 106
├── .env.example - OBFUSCATION_ENCODED_BLOB Low
Contains a long base64 shaped string in a file that should be readable.
assets/logo.svg, line 1
<svg xmlns="http://www.w3.org/2000/svg" version="1.1" xmlns:xlink="http://www.w3.org/1999/xlink" xmlns:svgjs="http://svgjs.dev/svgjs" width="800" height="800" viewBox="0 0 800 800" - SECRETS_ENV_READ Note
Reads an environment variable whose name contains KEY, SECRET, TOKEN, PASSWORD or CREDENTIAL.
skills/kafka-python-client/references/common-template.py, line 52
config["API_KEY"] = os.environ.get("API_KEY", "")
Any High, or two or more Medium findings, give D. One Medium gives C. Low findings or a security Note give B. Each code names a finding behind the letter.
Grades are a hygiene check of the source at the commit shown, on the date checked, not a security audit or a guarantee. The free directory grades are automated. Before release, a PlugVet engineer reviews every paid report and any grade we hold back, including all F grades, against the source code and the evidence we quote.
What was checked
Plain notes from the hygiene checks.
Permissions
Pass
No shell or command call was found in the code. This check does not read permissions an entry declares. A permission line to run shell commands and write or edit files was found in this repository, and it may apply to this entry.
Install and update
Pass
No install-time script found, and dependencies are pinned or absent.
Network
Concern
can reach a host that is not written as a fixed address.
NETWORK_NO_FIXED_HOST
skills/kafka-python-client/references/common-template.py, line 143
resp = requests.get(url, auth=auth, timeout=timeout)
skills/kafka-python-client/references/tests-template.py, line 125
with patch("common.requests.get") as mock_get:
skills/kafka-python-client/references/tests-template.py, line 133
with patch("common.requests.get") as mock_get:
Secrets
Concern
reads a credential or environment file.
SECRETS_ENV_READ SECRETS_PATH_DOTENV
skills/kafka-python-client/SKILL.md, line 106
├── .env.example
skills/kafka-python-client/SKILL.md, line 336
- .env.example
skills/kafka-python-client/references/common-template.py, line 52
config["API_KEY"] = os.environ.get("API_KEY", "")
Show more
skills/kafka-python-client/references/common-template.py, line 30
"""Load configuration from `.env` (if present) and environment variables.
skills/kafka-python-client/references/common-template.py, line 33
works in containers where `.env` is not mounted.
skills/kafka-python-client/references/common-template.py, line 35
dotenv_path = Path(__file__).parent / ".env"
skills/kafka-python-client/references/common-template.py, line 53
config["API_SECRET"] = os.environ.get("API_SECRET", "")
skills/kafka-python-client/references/common-template.py, line 54
config["SR_API_KEY"] = os.environ.get("SR_API_KEY", "")
skills/kafka-python-client/references/common-template.py, line 55
config["SR_API_SECRET"] = os.environ.get("SR_API_SECRET", "")
skills/kafka-python-client/references/common-template.py, line 61
"Copy .env.example to .env and fill them in."
skills/kafka-python-client/references/common-template.py, line 82
"KAFKA_ENV=cloud requires API_KEY and API_SECRET in .env"
skills/kafka-python-client/references/common-template.py, line 105
"KAFKA_ENV=cloud requires SR_API_KEY and SR_API_SECRET in .env"
Agent instructions
Pass
No instruction to ignore earlier instructions or to hide a step.
Obfuscation
Concern
contains an encoded blob in a file that should be readable.
OBFUSCATION_ENCODED_BLOB
assets/logo.svg, line 1
<svg xmlns="http://www.w3.org/2000/svg" version="1.1" xmlns:xlink="http://www.w3.org/1999/xlink" xmlns:svgjs="http://svgjs.dev/svgjs" width="800" height="800" viewBox="0 0 800 800"
Licence
Pass
A licence file is present (LICENSE).
Maintainer activity
Pass
The latest commit is within the last 365 days.
Note
Hygiene check of commit 8cee08b1681c. can reach a host that is not written as a fixed address. reads a credential or environment file. contains an encoded blob in a file that should be readable.
Date and source
Date checked:
github.com
Commit graded: 8cee08b1681c38c1daef956ce8b3d9c515fde765
This link goes to the original host. PlugVet does not host or check what you download from there, and installing it is your own decision and risk.