Atlas / MCP servers / systemcraftsman / Strimzi Kafka CLI

Strimzi Kafka CLICAUTION

mcp/systemcraftsman/strimzi-kafka-cli

Command Line Interface and MCP Server for the Strimzi Kafka Operator

Verdict
CAUTION
Grade
B
Trust score
89 /100
Exposed tools
42 25r · 8w · 9d
Transport
stdio
License
Apache-2.0
Stars
92
01

Overview

From the repository's own README, as read at the audited commit. Badges and raw HTML are left out.

[](https://pypi.org/project/strimzi-kafka-cli/) [](https://pepy.tech/project/strimzi-kafka-cli) [](http://www.apache.org/licenses/LICENSE-2.0) [](https://github.com/strimzi/strimzi-kafka-operator/releases/tag/1.0.0) [](https://github.com/systemcraftsman/strimzi-kafka-cli#mcp-server)

Strimzi Kafka CLI is a CLI that helps traditional Apache Kafka users -both developers and administrators- to easily adapt to Strimzi, a Kubernetes operator for Apache Kafka.

The main intention is to ramp up Strimzi usage by creating a similar CLI experience with the traditional Apache Kafka tools that mostly starts with kafka-* prefix under the bin directory in an ordinary Kafka package.

Strimzi Kafka CLI uses the kfk command as an abbreviation for "Kafka For Kubernetes" or simply "k a f k a" which reminds of the kafka-* prefix of the ordinary Kafka script file names.

While having similar set of commands or options for some of the common objects, Strimzi Kafka CLI has some extra capabilities for managing or configuring Strimzi relat

Read from source at commit d5e1b93196b3OBSERVED · 2026-10-07
02

Connect

Built from this server's own package name, version and transport as found in its source — not copied from anyone's documentation, so it cannot drift against a page we do not control.

claude-code (pypi)
claude mcp add strimzi-kafka-cli -- None strimzi-kafka-cli==1.0.0b13
03

Exposed tools (42)

25 read · 8 write · 9 destructive. Blast radius: 9 tools can delete or overwrite — an agent that can be talked into calling a tool can be talked into calling this one.

ToolRiskDescription
add_or_remove_aclsdestructiveAdd or remove ACLs on Kafka.
alter_connectreadAlter a KafkaConnect cluster.
alter_connectorreadAlter a KafkaConnector.
alter_kafka_configreadAlter cluster-level Kafka configuration.
alter_topicreadAlter a Kafka topic.
alter_userreadAlter a Kafka user.
backup_connectreadBack up a Kafka Connect cluster and its connectors to a gzip archive.
backup_kafkareadBack up a Kafka cluster and its resources to a gzip archive.
create_connectwriteCreate a KafkaConnect cluster.
create_connectorwriteCreate a KafkaConnector.
create_kafkawriteCreate a Kafka cluster from template.
create_mirror_maker_2writeCreate a KafkaMirrorMaker2 resource.
create_node_poolwriteCreate a KafkaNodePool resource.
create_topicwriteCreate a Kafka topic.
create_userwriteCreate a Kafka user.
delete_connectdestructiveDelete a KafkaConnect cluster.
delete_connectordestructiveDelete a KafkaConnector.
delete_kafkadestructiveDelete a Kafka cluster.
delete_mirror_maker_2destructiveDelete a KafkaMirrorMaker2 resource.
delete_node_pooldestructiveDelete a KafkaNodePool resource.
delete_topicdestructiveDelete a Kafka topic.
delete_userdestructiveDelete a Kafka user.
get_connectreadGet a KafkaConnect cluster resource.
get_connectorreadGet a KafkaConnector resource.
get_kafkareadGet a Kafka cluster resource.
get_kafka_statusreadGet the status and conditions of a Kafka cluster.
get_mirror_maker_2readDescribe a KafkaMirrorMaker2 resource.
get_node_poolreadDescribe a KafkaNodePool resource.
get_topicreadGet a Kafka topic resource.
get_userreadGet a Kafka user resource.
get_versionreadGet Strimzi CLI and Strimzi version information.
install_operatorwriteInstall the Strimzi Kafka Operator.
list_connectorsreadList KafkaConnectors.
list_connectsreadList KafkaConnect clusters.
list_kafkasreadList all Kafka clusters in the namespace.
list_mirror_maker_2sreadList KafkaMirrorMaker2s in the namespace.
list_node_poolsreadList KafkaNodePools in the namespace.
list_topicsreadList Kafka topics in the specified cluster.
list_usersreadList Kafka users in the specified cluster.
restore_connectreadRestore a Kafka Connect cluster and its connectors from a backup archive.
restore_kafkareadRestore a Kafka cluster and its resources from a backup archive.
uninstall_operatordestructiveUninstall the Strimzi Kafka Operator.
04

Trust audit

CAUTIONgrade B · trust 89/100 Install with care. The audit found things worth knowing before you trust its output.

LayerWhat it checksResult
L0Provenance & inventoryPASS
L1Static analysis of the codeFAIL
L2Instruction surface (what it tells the agent)PASS
L3Class-specific surfaceWARN
L4Behavioural (sandbox)SKIPPED

What the source does

Filesystem
declared (4 observation(s))
Network
declared (1 observation(s))
Shell
none-observed
Dependencies
pinned
Secrets in source
none-found

Findings (7)

HIGHFilesystem / path · fs.credential_store · CWE-22, CWE-59
Dockerfile:11
COPY tests/files/yaml/kubeconfig /home/kfkuser/.kube/config
Why it matters. touches a credential store
MEDIUMFilesystem / path · mcp.destructive_tools · CWE-22, CWE-59
add_or_remove_acls, delete_connect, delete_connector, delete_kafka, delete_mirror_maker_2, delete_node_pool, delete_topic, delete_user, uninstall_operator
Why it matters. 9 tool(s) can delete or overwrite
Fix. prefer a read-only mode or scoped tokens; the page states the blast radius
LOWInventory / provenance · inv.hidden_file · CWE-1104
.pre-commit-config.yaml
.pre-commit-config.yaml
Why it matters. hidden member outside the usual dotfiles
Fix. review its purpose
LOWFilesystem / path · fs.credential_store · CWE-22, CWE-59
.github/workflows/build.yml:37
mkdir ~/.kube
Why it matters. touches a credential store
LOWFilesystem / path · fs.credential_store · CWE-22, CWE-59
.github/workflows/build.yml:38
cp tests/files/yaml/kubeconfig ~/.kube/config
Why it matters. touches a credential store
LOWFilesystem / path · fs.credential_store · CWE-22, CWE-59
.github/workflows/integration-test.yml:31
mkdir -p ~/.kube
Why it matters. touches a credential store
LOWFilesystem / path · fs.credential_store · CWE-22, CWE-59
.github/workflows/integration-test.yml:32
kind get kubeconfig --name strimzi-cli-test > ~/.kube/config
Why it matters. touches a credential store

Gates applied: no_behavioural_pass.

Audited 2026-10-07 · audit v0.4.1 · source sha d5e1b93196b3full audit observations/trust-audit/mcp-server/systemcraftsman__strimzi-kafka-cli.json · Report an issue / request a re-scan
05

Audit history

Every audit this server has had. A grade with a past is a grade somebody is still checking.

DateSourceVerdictGradeScoreChange
2026-10-07d5e1b93196b3CAUTIONB89first audit
06

Questions

What is the Strimzi Kafka CLI MCP server?

Command Line Interface and MCP Server for the Strimzi Kafka Operator

What tools does Strimzi Kafka CLI expose?

42 in total: 25 read-only, 8 that write, and 9 that can delete or overwrite (add_or_remove_acls, delete_connect, delete_connector, delete_kafka, delete_mirror_maker_2). Every one is listed on this page with its risk.

Is Strimzi Kafka CLI safe to connect to an agent?

With care. The audit graded it B (89/100) and found 7 things worth knowing before you trust this server, listed below with the exact line each was found on. Separately from the audit: 9 of its tools can destroy data, so scope the token you give it to what you actually need.

What credentials does Strimzi Kafka CLI need?

No credential environment variables were found in its source, so it appears to need none.

How does Strimzi Kafka CLI run?

It speaks stdio, so it runs as a local process your client starts. It is published on PyPI as strimzi-kafka-cli.

How current is this page?

The grade is for one exact copy of the source (d5e1b93196b3), read on 2026-10-07. The repository is watched and re-audited when it changes.

Advertisement