-
batchFrequencyMs
Long batchFrequencyMs
Frequency of messaging between components
-
batchSize
Long batchSize
Default max batch size for batch-based persist readers and writers
-
identifier
String identifier
Name of streams pipeline
-
parallelism
Long parallelism
Default parallelism for processors
-
providerTimeoutMs
Long providerTimeoutMs
Kill the stream if all providers supply nothing for this long.
-
providerWaitMs
Long providerWaitMs
Wait this long before beginning polling providers.
-
queueSize
Long queueSize
Size of inter-component buffers
-
shutdownCheckDelay
Long shutdownCheckDelay
Initial delay before checking for shutdown
-
shutdownCheckInterval
Long shutdownCheckInterval
Recurring delay between checking for shutdown
-
startedAt
Long startedAt
Timestamp of beginning of stream execution