package serialization

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. abstract class AbstractConfluentKafkaAvroDeserializer extends AbstractKafkaAvroDeserializer

    This class basically do the same as AbstractKafkaAvroDeserializer but use our createDatumReader implementation with time conversions

  2. 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.

  3. abstract class ConfluentAvroKeyValueSerializationSchemaFactory extends KafkaSchemaBasedKeyValueSerializationSchemaFactory with ConfluentAvroSerializerFactory
  4. class ConfluentAvroPayloadDeserializer extends DatumReaderWriterMixin with RecordDeserializer with UniversalSchemaPayloadDeserializer
  5. class ConfluentAvroSerializationSchemaFactory extends KafkaSchemaBasedValueSerializationSchemaFactory with ConfluentAvroSerializerFactory
  6. trait ConfluentAvroSerializerFactory extends AnyRef
  7. class ConfluentKafkaAvroDeserializer[T] extends AbstractConfluentKafkaAvroDeserializer with Deserializer[T]

    This is Kafka Avro Deserialization class.

    This is Kafka Avro Deserialization class. All events will be deserialized to provided schema.

  8. trait ConfluentKafkaAvroDeserializerFactory extends LazyLogging
  9. 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.

  10. class ConfluentKeyValueKafkaAvroDeserializationFactory extends KafkaSchemaBasedKeyValueDeserializationSchemaFactory with ConfluentKafkaAvroDeserializerFactory
  11. trait UniversalSchemaPayloadDeserializer extends AnyRef

Value Members

  1. object ConfluentAvroPayloadDeserializer
  2. object ConfluentJsonPayloadDeserializer extends UniversalSchemaPayloadDeserializer
  3. object ConfluentJsonSchemaPayloadDeserializer extends UniversalSchemaPayloadDeserializer
  4. object ConfluentKafkaAvroSerializer
  5. object GenericRecordSchemaIdSerializationSupport

Ungrouped