Packages

package source

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. class UniversalKafkaSourceFactory extends KafkaUniversalComponentTransformer[Source, ForSource] with SourceFactory with WithExplicitTypesToExtract with UnboundedStreamComponent

    This is universal kafka source - it will handle both avro and json TODO: Move it to some other module when json schema handling will be available

Value Members

  1. object UniversalKafkaSourceFactory extends Serializable

Ungrouped