Shutdown hook in kStream

Runtime.getRuntime().addShutdownHook(new Thread(streams::close));