package serialization
Ordering
- Alphabetic
Visibility
- Public
- All
Type Members
-
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.
-
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
- object ConfluentKafkaAvroSerializer