Really Nice, I have created similar implementation for myself with Python 3 which support local filesystem or S3 as Sink.

https://github.com/116davinder/apache-kafka-backup-and-restore