This project demonstrates a real-time AI "Meeting Coach" showcasing the use of Confluent Cloud for Apache Flink AI Inference functions to build a real-time Retrieval-Augmented Generation (RAG) pipeline. The demo uses both a static knowledge base of sales documents and real-time simulated meeting data.

Parallel Apache Kafka client wrapper with per message ACK, client side queueing, a simpler consumer/producer API with key concurrency and extendable non-blocking IO processing.

Demo applications and code examples for Apache Kafka's Streams API.

Confluent Docker images for Kafka MQTT

Kafka Connect suite of connectors for Cloud storage (Amazon S3)

Shared software among connectors that target distributed filesystems and cloud storage.