Streaming Agents
Build, deploy, and orchestrate event-driven agents natively on Apache Flink® to power intelligent real-time automation across your organization.
Always on, replayable, and production ready
Living in data streams to act on fresh context
Built on fully managed Flink and Kafka
What are Streaming Agents?
What are Streaming Agents?
Streaming Agents enable you to build, test, deploy, and orchestrate event-driven agents using fully managed Flink and Kafka on a unified platform. With access to real-time contextualized data, they’re uniquely suited for enterprise workflows – monitoring and taking instant, informed action the moment operational events occur.
Whether you’re automating fraud prevention or personalizing product recommendations, Streaming Agents help you turn agents from brittle demos into production-ready, event-driven multi-agent systems.
Watch Demo
NEW: Join us at AI Day for Developers in Boston on Sept. 24 for a hands-on Streaming Agents workshop and hackathon with a chance to win exciting prizes. Register now →
Unify stream processing and AI
Simplify development by embedding agents in the data stream and directly working with AI models in Flink. Combine stream processing jobs (e.g., join, filter, enrich) and agentic workflows in the same pipeline, reducing operational complexity while empowering every engineer to be an AI engineer using familiar Flink APIs.
Tap into fresh context
Enterprises need agents to be the eyes and ears for the business in motion, but most agents lack real-time awareness. Running as Flink jobs in stream processing pipelines, Streaming Agents can access the latest, most accurate view of the business, at the moment a decision needs to be made – zero data polling or delay. They’re always on, state-aware, and retain context over time.
Seamlessly integrate with any model, tool, and data system
Integrate without stitching together disparate systems. Use your preferred tools and Flink APIs with native support for connecting to large language models (LLMs) and embedding models, tool calling with Model Context Protocol (MCP), and data enrichment from other systems with External Tables and Vector Search.
Ensure agents are trustworthy and secure
Maintain full visibility and control with secure connections, RBAC, built-in replayability, dark mode testing, and governed, traceable event flows.
Unlock event-driven multi-agent systems
Event-driven by design, Streaming Agents communicate without rigid dependencies, collaborate with other agents, and adapt to real-time inputs. Powered by Kora Engine, this unlocks reliable multi-agent patterns such as Orchestrator-Worker or Hierarchical to enable unlimited enterprise use cases.
Kafka’s immutable log provides replayability where Streaming Agents have memory and context is event-based – this helps you easily rewind, debug, test, and audit agent behavior to iterate faster, safely.
Automate high-volume business processes
Real-time product personalization
Streaming Agents ingest live customer interaction data, leverage context from internal systems (e.g., purchase history, clickstream, inventory), use an LLM to understand preferences and intent, and then instantly tailor product recommendations–continuously adapting to maximize engagement and conversion.
Anomaly detection & investigation
By monitoring operational data streams–e.g., call drop rates, signal quality, bandwidth usage–Streaming Agents detect unusual patterns, correlate signals across data sources, use an LLM to assess likely root causes and impact, then trigger remediation steps or escalate to the right teams–enabling faster mean time to resolution (MTTR).
Competitive pricing
Streaming Agents automatically trigger MCP tools to scrape competitor websites for real-time pricing on ordered products, update the customer’s order to match lower prices, notify the customer of their savings via email, and log each price match in a CRM system.
“Good AI needs good data. Confluent is our trusted source of truth… the data streaming platform provides context and orchestration for our AI agents to automate workflows and accelerate our smart city transformation.”
Kafka와 Flink를 활용한 사례 연구를 미리 시작하세요. 지금 Confluent Cloud 계정을 만들고 활성화하면 첫 30일 동안 사용 가능한 $400의 무료 크레딧이 제공됩니다.