v0.1.0

StreamOps Agent v0.1.0

AI-powered operations agent for Apache Flink streaming pipelines.

Highlights

• Real-time anomaly detection: monitors Kafka and Flink metrics to detect latency spikes, throughput drops, backpressure, checkpoint failures, and memory pressure
• AI-powered diagnosis: routes detected anomalies to Claude for root cause analysis and remediation recommendations via MCP server
• Event simulation: generates realistic streaming telemetry (metrics, logs, heartbeats) with injectable fault scenarios
• Flink 2.0 stream processor: deserializes, enriches, and routes events through anomaly detection operators
• MCP server interface: exposes tools for querying metrics, listing anomalies, running scenarios, and getting AI recommendations
• Docker Compose stack: one-command deployment with Kafka, Flink, and the MCP server
• 37 tests covering metric generation, anomaly detection, event deserialization, and scenario execution

Components

JAR	Description
stream-processor.jar	Flink job that processes streaming events and detects anomalies
event-simulator.jar	Generates realistic telemetry data with fault injection

Usage

docker compose up -d

See the README for full setup and MCP server configuration.

Requirements

• JDK 17+
• Docker and Docker Compose
• Anthropic API key (for AI diagnosis)