Home > MCP Servers > quickstart-streaming-agents

quickstart-streaming-agents

Build, deploy, and orchestrate event-driven agents natively on Apache Flink® and Apache Kafka®

agentic-ai agentic-framework agents ai azure-ai bedrock claude embeddings python rag

Why this rank:Strong adoptionRecent releaseHealthy release cadence

Description

Build, deploy, and orchestrate event-driven agents natively on Apache Flink® and Apache Kafka®

README

Streaming Agents on Confluent Cloud Quickstart

Build real-time AI agents with Confluent Cloud Streaming Agents. This quickstart includes three hands-on labs:

Lab	Description
Lab1 - Price Matching Orders With MCP Tool Calling	*NEW!* Now using new Agent Definition (CREATE AGENT) syntax. Price matching agent that scrapes competitor websites and adjusts prices in real-time.
Lab2 - Vector Search & RAG	Vector search pipeline template with retrieval augmented generation (RAG). Use the included Flink documentation chunks, or bring your own documents for intelligent document retrieval.
Lab3 - Agentic Fleet Management Using Confluent Intelligence	End-to-end boat fleet management demo showing use of Agent Definition, MCP tool calling, vector search, and anomaly detection.
Lab4 - Public Sector Insurance Claims Fraud Detection Using Confluent Intelligence	Real-time fraud detection system that autonomously identifies suspicious claim patterns in disaster insurance claims applications using anomaly detection, pattern recognition, and LLM-powered analysis.

Prerequisites

Required accounts & credentials:

Setup guide)

Required tools:

Confluent CLI - must be logged in
Docker - for Lab1 & Lab3 data generation only
Git
Terraform
uv
AWS CLI or Azure CLI tools for generating API keys

Installation commands (Mac/Windows)

**Mac:**

brew install uv git python && brew tap hashicorp/tap && brew install hashicorp/tap/terraform && brew install --cask confluent-cli docker-desktop && brew install awscli # or azure-cli

Windows:

winget install astral-sh.uv Git.Git Docker.DockerDesktop Hashicorp.Terraform ConfluentInc.Confluent-CLI Python.Python

🚀 Quick Start

1. Clone the repository and navigate to the Quickstart directory:

git clone https://github.com/confluentinc/quickstart-streaming-agents.git
cd quickstart-streaming-agents

2. Auto-generate AWS Bedrock or Azure OpenAI keys:

# Creates API-KEYS-[AWS|AZURE].md and auto-populates them in next step
uv run api-keys create

One command deployment:

uv run deploy

That's it! The script will autofill generated credentials and guide you through setup and deployment of your chosen lab(s).

Note

See the Workshop Mode Setup Guide for details about auto-generating API keys and tips for running demo workshops.

Directory Structure

quickstart-streaming-agents/
├── terraform/                          
│   ├── core/                           # Shared Confluent Cloud infra for all labs
│   ├── lab1-tool-calling/              # Lab1-specific infra
│   ├── lab2-vector-search/             # Lab2-specific infra
│   └── lab3-agentic-fleet-management/  # Lab3-specific infra
│   └── lab4-pubsec-fraud-agents        # Lab4-specific infra
├── deploy.py                           # Start here with uv run deploy
└── scripts/                            # Python utilities invoked with uv

Cleanup

# Automated
uv run destroy

Sign up for early access to Flink AI features

For early access to exciting new Flink AI features, fill out this form and we'll add you to our early access previews.

Release History

Version	Changes	Urgency	Date
master@2026-08-21	Latest activity on master branch	High	8/21/2026
0.0.0	No release found — using repo HEAD	High	4/9/2026

Dependencies & License Audit

Loading dependencies...

Similar Packages

samplesAgent samples built using the Strands Agents SDK.main@2026-09-01

sdk-pythonA model-driven approach to building AI agents in just a few lines of code.typescript/v1.16.0

agentic-rag📄 Enable smart document and data search with AI-powered chat, vector search, and SQL querying across multiple file formats.main@2026-09-09

PageIndex📑 PageIndex: Document Index for Vectorless, Reasoning-based RAGv0.2.14

nexentNexent is a zero-code platform for auto-generating production-grade AI agents using Harness Engineering principles — unified tools, skills, memory, and orchestration with built-in constraints, feedbacv2.5.0

More in MCP Servers

difyProduction-ready platform for agentic workflow development.

tabularisA lightweight, cross-platform database client for developers. Supports MySQL, PostgreSQL and SQLite. Hackable with plugins. Built for speed, security, and aesthetics.

ai-agents-from-zero 🚀 2026 最系统的 AI Agent 速成指南｜智能体实战教程 · 完整学习路径 + 实战项目 + 面试题库 · 对标大模型应用开发工程师岗位 · 覆盖LangChain / LangGraph / Coze / Dify / MCP / skills / LLM / RAG / 提示词 · 企业级部署与微调 · 从0到企业级落地 + 从学习到上线项目 + 面试准备一体化

openclaw.netSelf-hosted OpenClaw gateway + agent runtime in .NET (NativeAOT-friendly)