Packages

package sink

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Type Members

  1. class UniversalKafkaSinkFactory extends KafkaUniversalComponentTransformer[Sink, ForSink] with SinkFactory
  2. trait UniversalKafkaSinkImplFactory extends AnyRef

Value Members

  1. object UniversalKafkaSinkFactory extends Serializable

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

Ungrouped