KafkaReceiverPolicy

constructor(prefetchBatches: Int = DEFAULT_PREFETCH_BATCHES, maxDeferredCommits: Int = DEFAULT_MAX_DEFERRED_COMMITS)