kafka_topic_create · RedisNexus MCP: Risk & Policy

WHAT IT DOES

What kafka_topic_create does on RedisNexus

AI agents use kafka_topic_create to create or update resources in RedisNexus — usually the action step of a workflow, after the agent has gathered context. Every call changes real data in your RedisNexus environment.

WHY IT NEEDS A POLICY

Why kafka_topic_create needs a policy

This tool creates new Kafka topics, which is a reversible Write operation (topics can be deleted). However, it carries medium severity because misconfiguration of production topics could impact data pipeline availability and integrity. The tool does not execute arbitrary code, delete data, or move money, so Write is the appropriate category rather than Execute or higher.

From the tool's definition Tool name 'kafka_topic_create' and description 'Create a Kafka topic' indicates irreversible creation of infrastructure resources.

Attacks that exploit this kind of access

Recommended rule Ready

Verdict

kafka_topic_create Rate-limited

kafka_topic_create stays usable, but capped — an agent stuck in a loop can't make hundreds of changes a minute. Everything else on the server is denied unless you say otherwise.

View as policy code

policy.json

{
  "version": "1",
  "default": "deny",
  "tools": {
    "kafka_topic_create": {
      "limits": [
        {
          "counter": "kafka_topic_create_rate",
          "window": "minute",
          "max": 30,
          "scope": "grant"
        }
      ]
    }
  }
}

LIMIT THIS TOOL →

Instant setup, no code required.

PolicyLayer is an MCP gateway: every tool call is checked against your rule before it reaches RedisNexus, so you can run agents against it safely.

FAQ

Questions about kafka_topic_create

What does the kafka_topic_create tool do? +

Create a Kafka topic with configurable partitions, replication, retention, and cleanup policy. It is categorised as a Write tool in the RedisNexus MCP Server, which means it can create or modify data. Consider rate limits to prevent runaway writes.

How do I enforce a policy on kafka_topic_create? +

Register the RedisNexus MCP server in PolicyLayer and add a rule for kafka_topic_create: allow, deny, rate-limit, or require approval. Point your MCP client at the PolicyLayer proxy URL and the rule is enforced on every call, before it reaches RedisNexus. Nothing to install.

What risk level is kafka_topic_create? +

kafka_topic_create is a Write tool with medium risk. Write tools should be rate-limited to prevent accidental bulk modifications.

Can I rate-limit kafka_topic_create? +

Yes. Add a rate_limit block to the kafka_topic_create rule in your PolicyLayer policy. For example, setting max: 10 and window: 60 limits the tool to 10 calls per minute. Rate limits are tracked per agent session and reset automatically.

How do I block kafka_topic_create completely? +

Set action: deny in the PolicyLayer policy for kafka_topic_create. The AI agent will receive a policy violation error and cannot call the tool. You can also include a reason field to explain why the tool is blocked.

What MCP server provides kafka_topic_create? +

kafka_topic_create is provided by the RedisNexus MCP server (rajkumar-madhu/mcp). PolicyLayer sits as a proxy in front of this server to enforce policies before tool calls reach the server.