serialization

Ordering

Visibility

class CharSequenceSerializer extends Serializer[AnyRef]
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.
trait KafkaDeserializationSchema[T] extends Serializable
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
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

Packages