kafka/me.ahoo.wow.kafka/KafkaPartitionedSource/KafkaPartitionedSource

KafkaPartitionedSource

constructor(consumers: (String) -> Consumer<String, ByteArray>, pollTimeout: Duration, dispatcher: CoroutineDispatcher, offsetGap: OffsetGapPolicy, observer: Observer = Observer.NONE)

constructor(consumers: (String) -> Consumer<String, ByteArray>, pollTimeout: Duration = KafkaOptions.DEFAULT_POLL_TIMEOUT, dispatcher: CoroutineDispatcher = VirtualThreads.dispatcher)