Skip to main content

MongoDB Atlas Stream Processing

Skill Verified Active
Part of:Mongodb

Manages MongoDB Atlas Stream Processing (ASP) workflows. Handles workspace provisioning, data source/sink connections, processor lifecycle operations, debugging diagnostics, and tier sizing. Supports Kafka, Atlas clusters, S3, HTTPS, and Lambda integrations for streaming data workloads and event processing. NOT for general MongoDB queries or Atlas cluster management. Requires MongoDB MCP Server with Atlas API credentials.

Purpose

To enable users to efficiently build, operate, and debug MongoDB Atlas Stream Processing (ASP) pipelines through a structured, tool-driven workflow.

Features

  • Workspace provisioning and management
  • Data source and sink connection configuration
  • Processor lifecycle operations (create, start, stop, modify, delete)
  • Debugging diagnostics and health reporting
  • Tier sizing and performance tuning

Use Cases

  • Setting up new Atlas Stream Processing workflows from scratch
  • Modifying existing processor pipelines and configurations
  • Debugging and troubleshooting failing or slow processors
  • Managing connections to Kafka, S3, Lambda, and other data sources/sinks

Non-Goals

  • Performing general MongoDB queries or data manipulation
  • Managing Atlas clusters directly (outside of stream processing connections)
  • Handling authentication outside of the MCP Server's configuration

Prerequisites

  • MongoDB MCP Server
  • Atlas API credentials (apiClientId, apiClientSecret)
  • Atlas project ID

Installation

First, add the marketplace

/plugin marketplace add mongodb/agent-skills
/plugin install agent-skills@mongodb-plugins

Quality Score

Verified
98 /100
Analyzed about 18 hours ago

Trust Signals

Last commit3 days ago
Stars111
LicenseApache-2.0
Status
View Source

Similar Extensions

Mongodb Search And Ai

100

Guides MongoDB users through implementing and optimizing Atlas Search (full-text), Vector Search (semantic), and Hybrid Search solutions. Use this skill when users need to build search functionality for text-based queries (autocomplete, fuzzy matching, faceted search), semantic similarity (embeddings, RAG applications), or combined approaches. Also use when users need text containment, substring matching ('contains', 'includes', 'appears in'), case-insensitive or multi-field text search, or filtering across many fields with variable combinations. Provides workflows for selecting the right search type, creating indexes, constructing queries, and optimizing performance using the MongoDB MCP server.

Skill
mongodb

Mongodb Mcp Setup

100

Guide users through configuring key MongoDB MCP server options. Use this skill when a user has the MongoDB MCP server installed but hasn't configured the required environment variables, or when they ask about connecting to MongoDB/Atlas and don't have the credentials set up.

Skill
mongodb

MongoDB Connection Optimizer

100

Optimize MongoDB client connection configuration (pools, timeouts, patterns) for any supported driver language. Use this skill when working/updating/reviewing on functions that instantiate or configure a MongoDB client (eg, when calling `connect()`), configuring connection pools, troubleshooting connection errors (ECONNREFUSED, timeouts, pool exhaustion), optimizing performance issues related to connections. This includes scenarios like building serverless functions with MongoDB, creating API endpoints that use MongoDB, optimizing high-traffic MongoDB applications, creating long-running tasks and concurrency, or debugging connection-related failures.

Skill
mongodb

Fixflow

100

Execute coding tasks with a strict delivery workflow: build a full plan, implement one step at a time, run tests continuously, and commit by default after each step (`per_step`). Support explicit commit policy overrides (`final_only`, `milestone`) and optional BDD (Given/When/Then) when users ask for behavior-driven delivery or requirements are unclear.

Skill
majiayu000

Autoskill

100

Observe the user's screen via screenpipe, detect repeated research workflows, match them against existing scientific-agent-skills, and draft new skills (or composition recipes that chain existing ones) for the patterns not yet covered. Use when the user asks to analyze their recent work and propose skills based on what they actually do. Requires the screenpipe daemon (https://github.com/screenpipe/screenpipe) running locally on port 3030 — the skill has no other data source and will refuse to run if screenpipe is unreachable. All detection runs locally; only redacted cluster summaries reach the LLM.

Skill
K-Dense-AI

Tuning Incremental Sync Config

99

Change the sync configuration of an existing data warehouse schema — switch sync_type, pick a different incremental_field, set primary_key_columns, choose cdc_table_mode, or change sync_frequency. Use when the user asks "switch my orders table from full refresh to incremental", "this table is syncing too slowly / too frequently", "I need to pick a different incremental column", "set up CDC for this Postgres table", or when diagnosis of a failing sync pointed to an incremental-field or PK misconfiguration.

Skill
PostHog

© 2025 SkillRepo · Find the right skill, skip the noise.