Confluent Intelligence is a set of managed Confluent Cloud capabilities designed to support the development of real-time, context-aware AI systems, including AI agents, retrieval-augmented generation (RAG) pipelines, and streaming ML/inference workflows. The product is built on Confluent’s managed Apache Kafka and Apache Flink foundation. Confluent identifies an "AI context gap": production models and agents can fail when they do not have access to governed, fresh, replayable business context. Confluent Intelligence is intended to address that issue by combining stream processing, state management, and context-serving features.
Key components include:
- Streaming Agents (agents running as Flink jobs within stream processing pipelines)
- Real-Time Context Engine (serving structured, governed context to AI applications and agents, including via MCP integration)
- Built-in ML functions (for example, anomaly detection and forecasting) that operate within Flink-based streaming pipelines
(Official product overview.)