System properties reference

astra.bulkIngest.producerSleepMs

How long Astra will wait before starting the next bulk batch if the last batch was empty.

defaultValue

50

astra.bulkIngest.useKafkaTransactions

The preprocessor can write documents to kafka using transactions. Enable this to ensure that all documents are written using exactly once semantics and all kafka brokers for a partition acknowledge a write. Defaults to false.

astra.concurrent.query

The amount of concurrent queries that are permitted at the application level.

defaultValue

Runtime.getRuntime().availableProcessors() - 1

astra.s3CrtBlobFs.maxNativeMemoryLimitBytes

Sets the max allowable off-heap consumption of the AWS CRT client.

defaultValue

// Default to 5% of the heap size for the max crt off-heap or 1GiB (min for client) long jvmMaxHeapSizeBytes = Runtime.getRuntime().maxMemory(); long defaultCrtMemoryLimit = Math.max(Math.round(jvmMaxHeapSizeBytes * 0.05), 1073741824);

astra.recovery.maxRolloverMins

Maximum allowable time before a recovery task is failed and reintroduced into the processing pipeline.

defaultValue

90

astra.query.schemaTimeoutMs

Maximum amount of time before timing out individual indexer schema queries and returning the aggregate of returned schema.

defaultValue

500

astra.mapping.totalFieldsLimit

Maximum amount of total fields used by the mapper service for query parsing.

defaultValue

2500