wow-kafka/me.ahoo.wow.kafka/KafkaReceiverPolicy

KafkaReceiverPolicy

class KafkaReceiverPolicy(val prefetchBatches: Int = DEFAULT_PREFETCH_BATCHES, val maxDeferredCommits: Int = DEFAULT_MAX_DEFERRED_COMMITS, val retrySpec: Retry = defaultRetrySpec())

Constructors

Link copied to clipboard
constructor(prefetchBatches: Int = DEFAULT_PREFETCH_BATCHES, maxDeferredCommits: Int = DEFAULT_MAX_DEFERRED_COMMITS, retrySpec: Retry = defaultRetrySpec())

Types

Link copied to clipboard
object Companion

Properties

Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
val retrySpec: Retry
Generated by Dokka
© 2026 Copyright