Table of Contents

1. About
2. Documentation
3. Author

About Kafka Revive

The Kafka Revive library consists of multiple TypeScript files that provide a comprehensive solution for message re-processing in Apache Kafka using the KafkaJS client. It includes a ClientWrapper class that wraps around the KafkaJS client, allowing the creation of producers and consumers with simplified methods for connecting, subscribing, and processing messages. Additionally, the library provides a DLQManager class for managing Dead Letter Queues (DLQs), enabling the creation of DLQ topics, retrying failed messages, and handling error scenarios.

Please note that Kafka Revive is not officially associated with Apache Kafka.

Install

To incorporate Kafka Revive into your project, follow these steps:

Install Kafka Revive as an NPM package by executing the following command in your terminal:

npm install kafka-revive

Utilize Kafka Revive in your code by including it using the require keyword, just as you would with any other library:

const KafkaRevive = require("kafka-revive");

Documentation

1. ClientWrapper
2. ProducerWrapper
3. ConsumerWrapper
4. DLQManager

Author

Chao Chen