From kafka-skills
Audits Kafka security configuration across codebase and live cluster via Lenses MCP. Checks SASL, SSL/TLS, ACLs, and credentials.
How this skill is triggered — by the user, by Claude, or both
Slash command
/kafka-skills:kafka-security-audit [required: environment name][required: environment name]This skill is limited to the following tools:
The summary Claude sees in its skill listing — used to decide when to auto-load this skill
Audits Kafka security configuration across the codebase and infrastructure. Kafka clusters often start as PLAINTEXT in dev and never get properly secured for production.
Audits Kafka security configuration across the codebase and infrastructure. Kafka clusters often start as PLAINTEXT in dev and never get properly secured for production.
Target environment: $ARGUMENTS
Copy this checklist and track your progress:
Security Audit Progress:
- [ ] Step 1: Check environment health and tier
- [ ] Step 2: Scan codebase for security configuration
- [ ] Step 3: Audit authentication
- [ ] Step 4: Audit encryption
- [ ] Step 5: Audit secrets management
- [ ] Step 6: Generate report
references/security-properties.md)Use Lenses MCP tools to understand the environment:
check_environment_health - verify environment is healthy and agent is connectedget_environment - get environment tier (development, staging, production) to calibrate severity levels. A PLAINTEXT connection in dev is a suggestion; in production it's critical.Expected output: Environment tier (development/staging/production) and health status.
Validation: If the environment tier cannot be determined, default to production-level severity - it is safer to over-report.
Search the codebase for Kafka security configuration. Consult references/security-properties.md for the full list of authentication properties, encryption properties and files to scan.
Apply the authentication audit rules from references/security-properties.md. Key checks:
Apply the encryption audit rules from references/security-properties.md. Key checks:
Apply the secrets audit rules from references/security-properties.md. Key checks:
.gitignore entries (warning)Cross-reference findings with the environment tier from Lenses:
User says: "Audit Kafka security for the production environment"
Actions:
User says: "Is my dev Kafka cluster secure enough?"
Actions:
User says: "Check if there are any hardcoded Kafka credentials in the codebase"
Actions:
.env files tracked by git.gitignore includes credential files
Result: Focused report on secrets management onlyCause: Lenses get_environment returns no tier or a custom tier value.
Solution: Default to production-level severity. It is safer to over-report than under-report security issues.
Cause: Not running inside a git repository.
Solution: Check for .env files and report their presence. Note that git tracking could not be verified.
Cause: Words like "password" appear in documentation or comments rather than actual credentials. Solution: Report all findings but note the confidence level. Flag inline values as high confidence and reference-only mentions as low confidence.
## Security Audit Report
### Environment: {name} (tier: {development|staging|production})
### Critical (must fix)
- [file:line] Description of the security issue
Risk: {what could go wrong}
Remediation: {how to fix}
### Warning (should fix)
- [file:line] Description of the issue
Risk: {what could go wrong}
Remediation: {how to fix}
### Suggestion (consider improving)
- [file:line] Description of the issue
Recommendation: {how to improve}
### Summary
- X critical issues found
- Y warnings found
- Z suggestions found
- Environment tier: {tier}
- Authentication: {configured|missing}
- Encryption: {configured|missing}
- Secrets exposed: {yes|no}
npx claudepluginhub lensesio/agentic-engineering-for-apache-kafka --plugin kafka-skillsSecures Kafka and AMQ Streams deployments with TLS encryption, SASL/SSL authentication, and ACL/OPA authorization. Useful when configuring brokers, custom resources, or client connectivity.
Audits how secrets, credentials, and certificates are stored, rotated, and accessed. Detects hardcoded secrets and guides migration to centralized secret managers like Vault or AWS Secrets Manager.
Conducts security audits for DevSecOps, reviews SDLC controls, CI/CD pipelines, threat models, vulnerabilities, authentication, authorization, and compliance frameworks.