Kafka To Asp

Converts MongoDB Kafka managed connector configurations (MongoDbAtlasSource / MongoDbAtlasSink) to equivalent Atlas Stream Processing processors. One-time migration workflow: reads connector JSON, validates it, maps fields to ASP pipeline stages, and creates connections and processors via the MongoDB MCP Server. Requires MongoDB MCP Server with Atlas API credentials.

mongodb a3dc985 5 files · 15.8 KB Updated

File contents

See commands/kafka-to-asp.md for the slash command definition.

Installation

Copy commands/kafka-to-asp.md to ~/.claude/commands/kafka-to-asp.md to make /kafka-to-asp available globally, or to .claude/commands/kafka-to-asp.md in any project for project-scoped use.

What it does

Accepts one or more Kafka managed connector config files (or pasted JSON) and creates the equivalent Atlas Stream Processing resources:

  • MongoDbAtlasSource$source (Atlas change stream) + $emit (Kafka topic)
  • MongoDbAtlasSink$source (Kafka topic) + $merge (Atlas collection)

Uses the mongodb:atlas-stream-processing skill and MongoDB MCP tools under the hood.

mongodb/ASP_example/tree/main/ASP_tools/kafka-to-asp commit a3dc985475

Frequently asked questions

npx skillmds@latest add mongodb/kafka-to-asp