Packages

package serialization

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Package Members

  1. package jsonpayload

Type Members

  1. class AbstractConfluentKafkaAvroSerializer extends AbstractKafkaAvroSerializer with DatumReaderWriterMixin

    Abstract confluent serializer class.

    Abstract confluent serializer class. Serialize algorithm is copy past from AbstractKafkaAvroSerializer.serializeImpl. Serializer try convert data (in most cases it will be GenericContainer) to indicated schema.

    There is some problem when GenericContainer has different schema then final schema - DatumWriter throws exception, because data could not support field from schema. When this situation has place wy try to convert data to provided schema by using AvroSchemaEvolution.alignRecordToSchema implementation.

  2. class ConfluentKafkaAvroSerializer extends AbstractConfluentKafkaAvroSerializer with Serializer[Any]

    This is Kafka Avro Serializer class.

    This is Kafka Avro Serializer class. All events will be serialized to provided schema.

Value Members

  1. object ConfluentKafkaAvroSerializer

Ungrouped