Shipping
AI/ML Functions
Native Flink functions for anomaly detection, fraud prevention, forecasting, sentiment analysis, and other machine learning capabilities executed directly within data streams.
Cluster Linking
Feature enabling real-time mirroring and replication of Kafka topics and metadata across clusters, supporting zero-downtime migrations and disaster recovery.
Confluent AI Developer Tools
MCP Server and Agent Skills tools that enable developers to build AI agents with access to real-time streaming data and data governance capabilities.
Developer tools including MCP Server and Agent Skills for building AI applications on top of Confluent's data streaming platform.
Confluent Cloud
Cloud-native data streaming platform powered by Kora engine, providing autoscaling, enterprise-grade performance, and 99.99% uptime SLA for production workloads.
Confluent Intelligence
A fully managed service on Confluent Cloud for building real-time, replayable, context-rich AI systems powered by Apache Kafka and Flink. Combines historical evaluation, continuous processing, and real-time serving for production AI applications.
Confluent Platform
Self-managed, cloud-native distribution of Apache Kafka with built-in governance, security, and operational tools for on-premises and private cloud deployments.
Embedding Actions
Converts any Kafka topic into a stream of vector embeddings to continuously supply up-to-date context for RAG and semantic search applications.
Kora
Cloud-native engine powering Confluent Cloud with autoscaling capabilities and 20-90%+ throughput savings compared to traditional Kafka deployments.
ML Preprocessing Functions
Transforms features into representations more suitable for downstream processors within streaming pipelines.
Model Context Protocol (MCP) Server
Provides secure and scalable integration with any model, tool, or data system via MCP for serving real-time context to AI applications.
Multivariate Anomaly Detection
Identifies unexpected deviations in real time using multivariate analysis to improve data quality and enable faster decision-making in streaming data.
Real-Time Context Engine
A fully managed service that delivers trustworthy, structured, real-time context to any AI app or agent via the Model Context Protocol (MCP). Serves live, governed data from enriched enterprise sources at low latency.
Real-Time Forecasting
Performs real-time analysis and forecasting on streaming data without requiring in-depth data science expertise. Enables actionable insights from live data streams.
Remote Model Inference
Invokes remote AI/ML models directly within Flink, providing a unified platform for both data processing and AI/ML tasks without separate infrastructure.
Stream Governance
Fully managed governance suite including Schema Registry for managing data formats (Avro, Protobuf, JSON Schema) and ensuring data quality across streaming pipelines.
Streaming Agents
A framework for building, testing, and deploying event-driven AI agents that run natively on Kafka and Flink. Agents have access to real-time contextualized data to monitor events and take instant, informed action.
Tableflow
Converts Kafka topics to tables in a few clicks, simplifying data access and making streaming data more accessible.
Announced
Confluent Cloud (Q2 2026 Update)
Updated Confluent Cloud platform with enhanced accessibility for Flink and Kafka for AI-ready streaming, designed to make data and pipelines more accessible for AI workflows.