package universal
Ordering
- Alphabetic
Visibility
- Public
- All
Type Members
- class ConfluentKeyValueUniversalKafkaDeserializationFactory extends KafkaSchemaBasedKeyValueDeserializationSchemaFactory with ConfluentUniversalKafkaDeserializerFactory
- class ConfluentUniversalKafkaDeserializer[T] extends Deserializer[T] with UniversalSchemaIdFromMessageExtractor
- trait ConfluentUniversalKafkaDeserializerFactory extends LazyLogging
- class ConfluentUniversalKafkaSerializationSchemaFactory extends KafkaSchemaBasedValueSerializationSchemaFactory
- class InvalidSchemaIdHeader extends IllegalArgumentException
- class MessageWithoutSchemaIdException extends IllegalArgumentException
- class MismatchReaderWriterSchemaException extends IllegalArgumentException
- case class SchemaIdWithPositionedBuffer(value: Int, buffer: ByteBuffer) extends Product with Serializable
- trait UniversalSchemaIdFromMessageExtractor extends AnyRef
Value Members
- object ConfluentUniversalKafkaSerde