library for reliable processing records received from kafka - View it on GitHub