package source
Ordering
- Alphabetic
Visibility
- Public
- Protected
Type Members
- 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
- object UniversalKafkaSourceFactory extends Serializable