Packages

package sink

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. class KafkaAvroSinkFactory extends KafkaUniversalComponentTransformer[Sink] with SinkFactory
  2. class KafkaAvroSinkFactoryWithEditor extends KafkaUniversalComponentTransformer[Sink] with SinkFactory
  3. trait KafkaAvroSinkImplFactory extends AnyRef
  4. class UniversalKafkaSinkFactory extends KafkaUniversalComponentTransformer[Sink] with SinkFactory
  5. trait UniversalKafkaSinkImplFactory extends AnyRef

Value Members

  1. object AvroSinkSingleValueParameter
  2. object AvroSinkValueParameter
  3. object KafkaAvroSinkFactory extends Serializable
  4. object KafkaAvroSinkFactoryWithEditor extends Serializable
  5. 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