Symfony Messenger bundle that enables the use of Kafka as a transport, allowing seamless integration with event-driven architectures. It offers message production and consumption, serialization/deserialization, selective message handling, enhanced traceability, and optional schema validation with Apache Avro support.
Modern Java persistence framework for Event-driven systems. Built-in outbox pattern. Atomic transactions with domain events. Spring, Quarkus, Micronaut, or pure Java
A Kafka router for Go, built on IBM/sarama (https://github.com/IBM/sarama): register a handler per topic and get consumer-group consumption, composable retry chains (in-process and retry-topic based), dead-letter queues, and bounded worker pools — with at-least-once delivery and per-partition ordering on the happy path.
Queue Abstraction Layer provides a highly flexible and extensible queue interface that provides a unified way to interact with different queue backends
Go project generator CLI: scaffold production-ready REST & GraphQL APIs, web apps and Kafka/RabbitMQ/Redis workers with Clean (Hexagonal) Architecture. Echo, Gin, Chi, Gorilla or net/http; Postgres, MySQL, MongoDB, SQLite, DynamoDB & more; Docker, CI, JWT, OpenAPI/Swagger and OpenTelemetry built in.
A lightweight, production-ready Go library for building event-driven architectures. It provides a high-level abstraction over popular message brokers like Kafka and RabbitMQ, featuring background delivery, automatic retries with backoff, and robust Dead Letter Queue (DLQ) support.
Gamified, event-driven Telegram bot for language learning. Built with Go microservices, it leverages gRPC, Kafka, PostgreSQL, and multi-instance Redis. Features algorithmic tasks, the Shiritori word game, smart caching, and a local NLP pipeline (Vosk/RHVoice/Ollama) for offline voice and AI chatting. Designed for high resilience and scale.