
8/19/2025 · Hannah Miao
What this post added
Introduces Streaming Agents in Open Preview, enabling the building, deployment, and orchestration of event-driven AI agents directly within stream processing pipelines on Apache Kafka and Apache Flink. Key features in preview include tool calling with MCP, Connections for secure and reusable integrations with models and databases, and external tables/search for data enrichment. GA features include AI model inference and embeddings within Flink SQL, and built-in ML functions for time-series forecasting and anomaly detection. Also introduces Custom Single Message Transforms (SMTs) for fully managed connectors, allowing users to upload and manage their own transformation logic. Expands Tableflow functionality with Delta Lake and Databricks Unity Catalog integration, including automated schema evolution and table maintenance, and upsert materialization for CDC. Cluster Linking is now available on Google Cloud.