diff --git a/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/StorageServiceImpl.java b/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/StorageServiceImpl.java index 950774d23c9ebeb55bc6f04bc0779bdcff04b712..1135c6ccc5eb7b06211ee88e3d431145a5e25b6c 100644 --- a/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/StorageServiceImpl.java +++ b/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/StorageServiceImpl.java @@ -189,7 +189,7 @@ public class StorageServiceImpl implements StorageService { public RecordQueryResponse getRecordsByKind(RecordReindexRequest reindexRequest) throws URISyntaxException { Map<String, String> queryParams = new HashMap<>(); queryParams.put(RecordMetaAttribute.KIND.getValue(), reindexRequest.getKind()); - queryParams.put("limit", configurationProperties.getStorageRecordsBatchSize().toString()); + queryParams.put("limit", configurationProperties.getStorageGetRecordsByKindBatchSize().toString()); if (!Strings.isNullOrEmpty(reindexRequest.getCursor())) { queryParams.put("cursor", reindexRequest.getCursor()); }