Découvrez des projets open source de qualité, soumettez des projets anonymement, puis revendiquez et éditez votre propre projet.
Un peu de curiosité. Un monde de code ouvert.
THE FIRST COLLECTIONUne bibliothèque Go fournissant des blocs de construction bornés pour producteurs, consommateurs, relecture, inspection et transactions Kafka, enveloppant franz-go sans masquer les issues de livraison, le cycle de vie ou la politique de topics.
RisingWave est une plateforme de streaming d'événements conçue pour l'IA agentique, intégrant l'ingestion, le traitement et le service des données au sein d'un système unique.
Pipeline d'analyse en temps réel local utilisant un broker compatible Kafka (Redpanda) et PySpark Structured Streaming. Simule des événements clickstream, effectue une agrégation par fenêtres avec watermarking, le tout via docker-compose.
Watermill est une bibliothèque Go pour construire des applications événementielles avec des flux de messages. Elle offre une interface simple pour la messagerie pub/sub, prenant en charge Kafka, RabbitMQ, NATS, Redis, SQL, et plus encore.
KEFCore est un fournisseur Entity Framework Core dédié à Apache Kafka, qui permet aux applications .NET d'utiliser les topics Kafka comme base de données distribuée. Il prend en charge l'ensemble des fonctionnalités LINQ et permet d'interagir avec Kafka via les modèles EF Core standards, en masquant totalement le code client spécifique à Kafka.
Apache Kafka est une plateforme de streaming d'événements distribuée open-source conçue pour les pipelines de données haute performance, l'analyse en streaming et l'intégration de données.
Pathway est un framework ETL Python dédié au traitement de flux, à l'analyse en temps réel et aux pipelines IA incluant des LLM et des applications RAG. Il exécute du code Python sur un moteur Rust pour le calcul incrémental, prend en charge les données batch et streaming avec le même code, et se déploie via Docker et Kubernetes.
