S
Size: a a a
S
Д
SB
AH
AH
DS
Д
Д
AH
ak
ak
AH
AH
AH
AH
AH
Д
Д
S
SN
type StreamsConsumer =
static member Start<'M,'Req,'Res>
( log : ILogger, config : KafkaConsumerConfig, mapConsumeResult, parseStreamEvents,
prepare, handle, maxDop, stats : Streams.Scheduling.StreamSchedulerStats<OkResult<'Res>,FailResult>,
?pipelineStatsInterval, ?maxSubmissionsPerPartition, ?pumpInterval, ?logExternalState, ?idleDelay, ?maxBatches, ?maximizeOffsetWriting) =