Package-level declarations

Types

Link copied to clipboard

Thin Kotlin wrapper around Confluent's KafkaAvroDeserializer configured with the Schema Registry URL taken from KafkaInfraProperties and specific.avro.reader=true so the returned value is the generated SpecificRecord subclass (and not a generic record).

Link copied to clipboard

Thin Kotlin wrapper around Confluent's KafkaAvroSerializer configured with the Schema Registry URL taken from KafkaInfraProperties.