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

Companion

object Companion

Functions

fun create(options: KafkaOptions): KafkaPartitionedSource

A source whose consumers have options' configuration (KafkaOptions.consumerConfig).

fun create(options: KafkaOptions, offsetGap: OffsetGapPolicy, observer: Observer = Observer.NONE): KafkaPartitionedSource

A source whose consumers have options' configuration, its reads meeting an offset gap as offsetGap says and telling observer of it.