create
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.