The Kafka Update & 3,000 Downloads Milestone!
What's New?
Enhanced Kafka Integration (Event-Driven Architecture)
We've introduced a robust messaging layer built on top of kafkajs, following Clean Architecture principles:
BaseConsumer & BaseProducer: Abstract classes to handle connection lifecycle, heartbeats, and error handling out of the box.
Schema Validation with Zod: Every incoming Kafka message is now validated at the "gateway" level, ensuring your business logic only touches clean, typed data.
Connection Resilience: Improved connection promise logic to ensure producers are ready before any events are fired.