Small tool that stores (json) log from a kafka topic in files, while doing filtering, and some transformations. - View it on GitHub