Type Members

1.  class CharSequenceSerializer extends Serializer[AnyRef]
2.  case class FixedKafkaSerializationSchemaFactory[T](deserializationSchema: (String) => KafkaSerializationSchema[T]) extends KafkaSerializationSchemaFactory[T] with Product with Serializable

   Base implementation of pl.touk.nussknacker.engine.kafka.serialization.KafkaSerializationSchemaFactory Factory which always return the same schema.

   Base implementation of pl.touk.nussknacker.engine.kafka.serialization.KafkaSerializationSchemaFactory Factory which always return the same schema.

   T

   type of serialized object

   deserializationSchema

   schema which will be returned.

3.  trait KafkaDeserializationSchema[T] extends Serializable
4.  trait KafkaDeserializationSchemaFactory[T] extends Serializable

   Factory class for KeyedDeserializationSchema.

   Factory class for KeyedDeserializationSchema. It is extracted for purpose when for creation of KeyedDeserializationSchema are needed additional information like list of topics and configuration.

   T

   type of deserialized object

5.  trait KafkaSerializationSchemaFactory[T] extends Serializable

   Factory class for KeyedSerializationSchema.

   Factory class for KeyedSerializationSchema. It is extracted for purpose when for creation of KeyedSerializationSchema are needed additional information like list of topics and configuration.

   T

   type of serialized object