See the following: https://stackoverflow.com/questions/55865349/flush-size-when-using-kafka-connect-transform-archive-with-hdfssinkconnector