Starred repositories
A HTTP credential proxy and vault for AI agents
🔥 The API to search, scrape, and interact with the web for AI
Build, deploy, and orchestrate event-driven agents natively on Apache Flink® and Apache Kafka®
Orchestrate Claude Code, Codex, and Gemini sessions on a multiplayer canvas. Manage git worktrees, track AI conversations, and visualize your team's agentic work in real-time.
FastStream is a powerful and easy-to-use asynchronous Python framework for building asynchronous services interacting with event streams such as Apache Kafka, RabbitMQ, NATS, MQTT and Redis.
🌐 The open-source Agentic browser; alternative to ChatGPT Atlas, Perplexity Comet, Dia.
Jupyter Integration for Flink SQL via Ververica Platform
Python Examples for running Apache Flink® Table API on Confluent Cloud
Pocket Flow: Codebase to Tutorial
Apache Kafka® compatible broker with S3, PostgreSQL, SQLite, Apache Iceberg and Delta Lake
cryptography is a package designed to expose cryptographic primitives and recipes to Python developers.
Hackday project to replay an f1 session using bytewax, rerun and fastf1
Data Engine for Manual/Algo Trading: Download/Stream -> Clean -> Store. Supports Data Lakehouse Architecture. Clean Once and Forget.
The Virtual Feature Store. Turn your existing data infrastructure into a feature store.
This is RonDB, a distribution of NDB Cluster developed and used by Hopsworks AB. It also contains development branches of RonDB.
Bytewax custom sink for Azure AI Search
A drop-in Apache Spark replacement written in Rust, unifying batch processing, stream processing, and compute-intensive AI workloads.