Cribl Stream

Cribl Stream

pebbletek

Connects AI clients to Cribl Stream deployments for managing data processing configurations, pipelines, and monitoring system metrics through a standardized API interface.

Integrates with Cribl Stream deployments to enable management of configurations, pipelines, sources, and system metrics for DevOps teams and data engineers monitoring data processing workflows.

5200 views6Local (stdio)

What it does

  • Manage Cribl Stream configurations
  • Monitor data processing pipelines
  • Query system metrics and performance data
  • Configure data sources and destinations
  • View pipeline health and status
  • Modify data processing workflows

Best for

DevOps teams managing Cribl deploymentsData engineers monitoring processing workflowsOrganizations with complex data routing needsTeams automating Cribl administration tasks
Direct Cribl API integrationStandardized MCP tooling

About Cribl Stream

Cribl Stream is a community-built MCP server published by pebbletek that provides AI assistants with tools and capabilities via the Model Context Protocol. Streamline DevOps workflows by managing configurations, pipelines, and metrics with Cribl Stream for optimized data proc It is categorized under developer tools, analytics data.

How to install

You can install Cribl Stream in your AI client of choice. Use the install panel on this page to get one-click setup for Cursor, Claude Desktop, VS Code, and other MCP-compatible clients. This server runs locally on your machine via the stdio transport.

License

Cribl Stream is released under the MIT license. This is a permissive open-source license, meaning you can freely use, modify, and distribute the software.

Cribl MCP Server

npm version License

A Model Context Protocol (MCP) server that enables AI interactions with the Cribl API.

This server allows AI clients to discover and invoke data operations from a Cribl deployment, using standardised MCP tooling.

For detailed documentation, please see the docs/ directory. Here's a breakdown of the documentation files:

  • README.md (this file): Provides the highest-level introduction, quick start instructions, very basic examples, and links to the docs directory.
  • docs/configuration.md: Focuses specifically on the environment variables needed for configuration and explains the authentication modes. It's purely about setup.
  • docs/usage.md: Focuses on how to run the server (via npx or local development commands) and how to configure an MCP client to connect to it. It provides conceptual examples of invoking the tools.
  • docs/overview.md: Sits between the README and the specific config/usage docs. It details what the server offers in terms of authentication and, most importantly, provides a detailed reference guide to the available tools and their specific parameters/outputs, and future tools.

Getting Started

You can either install and run locally, or execute instantly via npx. npx saves you installing Git, dependencies, or any build tools. Both scenarios require you to have node later than version 16 installed:

Prerequisites

To run this server ensure the following:

  • Node.js is installed (version 16 or later recommended)
  • Internet access is available (to fetch the MCP server package from npm)

You can install Node.js from https://nodejs.org.

To verify your setup:

node -v
npx -v

Quick Start with npx

CRIBL_BASE_URL=https://your.cribl.cloud.instance CRIBL_AUTH_TYPE=cloud CRIBL_CLIENT_ID=abc123 CRIBL_CLIENT_SECRET=secret npx @pebbletek/cribl-mcp

Note: Running npx requires essential environment variables (like CRIBL_BASE_URL and authentication details) to be set either in your environment or passed directly on the command line for the server to connect successfully.

See docs/usage.md for advanced npx usage configuration, including relevant JSON for your MCP client, and required variables.

Local Development

  1. Browse to a high-level folder where you'll store the code base (cloning will create the containing folder). Clone the repo:
    git clone https://github.com/pebbletek/cribl-mcp.git
    cd cribl-mcp
    
  2. Install dependencies:
    npm install
    
  3. Copy the .env.example file and populate the required values:
    cp .env.example .env
    
  4. See usage.md > Local Development for running, building and starting the mcp server

See docs/configuration.md for details on environment variables and authentication, and docs/usage.md for running the server.

Available Tools

This server provides tools to interact with Cribl, including:

  • Listing Worker Groups/Fleets
  • Getting/Setting Pipeline configurations
  • Getting Source configurations
  • Restarting Worker Groups
  • Querying System Metrics (with filtering)

For a detailed list and usage instructions, see docs/usage.md.

Example Usage (Prompts)

Once connected via an MCP client (like Claude Desktop), you can interact with your Cribl instance using natural language prompts that leverage the available tools. Here are some examples:

  • Prompt: what sources are we ingesting?
    (you will need to allow the MCP client access to the tool)

    • Response will be something like:
      "To answer your question about ingested sources, let me check the available data sources in your Cribl Stream environment.
      <View result from cribl_getSources from Cribl (local)>

      Let me also check what pipelines are configured in your Cribl Stream environment:
      <View result from cribl_getPipelines from Cribl (local)>

      Based on the information I've retrieved from your Cribl Stream environment, here are the sources you are ingesting:
      Active Data Sources
      Your Cribl Stream instance has several configured data sources, with the following notable ones:

      1. HTTP/HTTPS Sources:
        HTTP source (port 10080)
        Cribl HTTP (port 10200)
        Splunk HEC (port 8088)...
      2. <etc.>

      Pipeline Configurations
      Your environment also has several pipelines configured for processing specific data types:

      1. Cisco ASA events - Filters and samples Cisco ASA security logs
      2. Cisco eStreamer data - Processes Cisco eStreamer data
      3. Palo Alto traffic events - Filters and samples Palo Alto traffic logs
      4. Windows Event Logs - Processes Windows security event logs

      These pipelines suggest you're ingesting network security logs from Cisco ASA firewalls, Cisco eStreamer (likely from Firepower/FTD devices), Palo Alto Networks firewalls, and Windows security events.
      Would you like more detailed information about any specific source or pipeline configuration?"

  • Prompt: what functions are processing the palo alto traffic?

    • Response:
      "Let me examine the functions that are processing the Palo Alto traffic in more detail:
      <View result from cribl_getPipelineConfig from Cribl (local)>

      Here's a detailed breakdown of how the Palo Alto traffic data is being processed in your Cribl Stream environment:
      Palo Alto Traffic Pipeline Functions
      1. Initial Filter (Eval):

      • Filter: sourcetype!='pan:traffic'
      • Description: Short-circuits (skips) all events that are NOT of sourcetype 'pan'
      • This is set as a final function, meaning if the condition is true, processing stops for that event

      2. Field Extraction (Regex Extract):

      • Extracts several key fields from the raw event using regex pattern matching:
        • __log_subtype: Identifies if the log is a start/end record
        • __src_zone and __dest_zone: Source and destination security zones
        • __transport: Transport protocol
        • __action: Action taken (allow, deny, etc.)
        • __bytes_in: Bytes received

      3. Filtering Events (Drop):

      • Filter: __log_subtype=='start'
      • Description: Drops all events with log subtype of 'start'
      • Rationale (from comment): "Drop events of log_subtype=start as they often have incorrect app assignment. Log_subtype=end contain better information."
      • etc."
  • Prompt: please update the pipeline to include start events as well as end events.

    • Response:
      "I'll update the Palo Alto traffic pipeline to include both "start" and "end" events by modifying the configuration. Let me make this change for you:
      <View result from cribl_getPipelineConfig from Cribl (local)>

      Now I'll update the pipeline configuration to keep both "start" and "end" events by disabling the drop function and updating the comments:
      <View result from cribl_setPipelineConfig from Cribl (local)>

      Now let's restart the worker group to apply these changes: <View result from cribl_restartWorkerGroup from Cribl (local)>

      The Palo Alto traffic pipeline has been successfully updated to include both "start" and "end" events. Here's what I modified:

      1. Disabled the Drop Function:

        • The function that was filtering out __log_subtype=='start' events has been disabled
        • This means both "start" and "end" session events will now be processed
      2. Updated the Comment:

        • Changed the comment from explaining why "start" events were being dropped to noting that both event types are now being kept for complete traffic visibility
      3. Restarted the Worker Group:

        • Applied the changes by restarting the Cribl Stream worker group

      The updated pipeline will now process both "start" and "end" events from your Palo Alto firewalls, giving you complete visibility into traffic sessions from initiation through completion. All other processing functions remain in place, including:

      • Field extraction for key traffic attributes
      • Sampling for zero-byte traffic and trusted zone traffic
      • Removal of unreliable date fields

      Your Palo Alto traffic data will now include the complete lifecycle of network connections while still maintaining the efficiency benefits of the sampling rules."

License

MIT

Alternatives

Related Skills

Browse all skills
ccxt-typescript

CCXT cryptocurrency exchange library for TypeScript and JavaScript developers (Node.js and browser). Covers both REST API (standard) and WebSocket API (real-time). Helps install CCXT, connect to exchanges, fetch market data, place orders, stream live tickers/orderbooks, handle authentication, and manage errors. Use when working with crypto exchanges in TypeScript/JavaScript projects, trading bots, arbitrage systems, or portfolio management tools. Includes both REST and WebSocket examples.

1
ai-sdk

Answer questions about the AI SDK and help build AI-powered features. Use when developers: (1) Ask about AI SDK functions like generateText, streamText, ToolLoopAgent, embed, or tools, (2) Want to build AI agents, chatbots, RAG systems, or text generation features, (3) Have questions about AI providers (OpenAI, Anthropic, Google, etc.), streaming, tool calling, structured output, or embeddings, (4) Use React hooks like useChat or useCompletion. Triggers on: "AI SDK", "Vercel AI SDK", "generateText", "streamText", "add AI to my app", "build an agent", "tool calling", "structured output", "useChat".

6
openai-knowledge

Use when working with the OpenAI API (Responses API) or OpenAI platform features (tools, streaming, Realtime API, auth, models, rate limits, MCP) and you need authoritative, up-to-date documentation (schemas, examples, limits, edge cases). Prefer the OpenAI Developer Documentation MCP server tools when available; otherwise guide the user to enable `openaiDeveloperDocs`.

4
ydc-ai-sdk-integration

Integrate Vercel AI SDK applications with You.com tools (web search, AI agent, content extraction). Use when developer mentions AI SDK, Vercel AI SDK, generateText, streamText, or You.com integration with AI SDK.

2
data-engineer

Build scalable data pipelines, modern data warehouses, and real-time streaming architectures. Implements Apache Spark, dbt, Airflow, and cloud-native data platforms. Use PROACTIVELY for data pipeline design, analytics infrastructure, or modern data stack implementation.

2
ccxt-csharp

CCXT cryptocurrency exchange library for C# and .NET developers. Covers both REST API (standard) and WebSocket API (real-time). Helps install CCXT, connect to exchanges, fetch market data, place orders, stream live tickers/orderbooks, handle authentication, and manage errors in .NET projects. Use when working with crypto exchanges in C# applications, trading systems, or financial software. Supports .NET Standard 2.0+.

1