KafkaReceiverPolicy

constructor(prefetchBatches: Int = DEFAULT_PREFETCH_BATCHES, maxDeferredCommits: Int = DEFAULT_MAX_DEFERRED_COMMITS, retrySpec: Retry = defaultRetrySpec())