Kafka Client API implementation that instead write to Redis Streams - View it on GitHub