kafka-message-bus
v0.0.1
Published
The Kafka Message Bus is an open-source wrapper for KafkaJS, adding support for deadletter topics and their handling to enhance message processing reliability.
Downloads
1
Readme
Kafka Message Bus 🚌✨
Introduction
Kafka Message Bus is a wrapper for KafkaJS, enhancing its functionality with deadletter topic support and handlers. It efficiently manages failed message processing in Kafka topics by redirecting them to deadletter topics for resolution, improving reliability in Kafka-based systems.
Getting Started
- Clone the repository:
git clone https://github.com/tomer555/kafka-message-bus.git
- Install dependencies:
npm install
Running Tests 🧪
Execute tests using:
npm run test
Kafka Provider Usage 📡
Configure, initialize, and use the Kafka provider in your application.
In-Memory Provider Usage 🧠
Set up and use the In-Memory provider for testing or lightweight handling.
Contributing
We welcome contributions! Here's how you can contribute:
- Fork the Repository: Create your own fork of the project.
- Create a Feature Branch: Work on new features or bug fixes in your own branch.
- Commit Your Changes: Make sure your changes are well-documented and tested.
- Submit a Pull Request: Submit your changes for review.
For a detailed guide on contributing to projects on GitHub, please refer to the GitHub contribution guide.
License
MIT License. See LICENSE.
For more details and advanced usage, visit the GitHub repository.