Merge "Add option to set kafka retention time for load tests"