High-level kafka client based on kafkajs with non-blocking retries of failed messages and easy configuration.
