Provides a KafkaJS-compatible handler for processing messages that facilitates publishing to delayed-retry or dead-letter topics - View it on GitHub