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.
Code ouvert. Horizons nouveaux.
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 COLLECTIONKEFCore 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.
Une 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.
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.