package schemaregistry
Ordering
- Alphabetic
Visibility
- Public
- All
Type Members
- class BasedOnVersionAvroSchemaDeterminer extends AvroSchemaDeterminer
- class ChainedSchemaIdFromMessageExtractor extends SchemaIdFromMessageExtractor
- case class ExistingSchemaVersion(version: Int) extends SchemaVersionOption with Product with Serializable
- class GenericRecordWithSchemaId extends Record
- case class GetSchemaIdArgs(headers: Headers, data: Array[Byte], isKey: Boolean) extends Product with Serializable
- case class IntSchemaId(value: Int) extends SchemaId with Product with Serializable
- class ParsedSchemaDeterminer extends AnyRef
- case class SchemaBasedSerdeProvider(serializationSchemaFactory: KafkaSchemaBasedSerializationSchemaFactory, deserializationSchemaFactory: KafkaSchemaBasedDeserializationSchemaFactory, recordFormatterFactory: RecordFormatterFactory, schemaValidator: SchemaValidator) extends Product with Serializable
- final case class SchemaError(message: String) extends RuntimeException with SchemaRegistryError with Product with Serializable
- sealed trait SchemaId extends AnyRef
- trait SchemaIdFromMessageExtractor extends Serializable
- case class SchemaIdWithPositionedBuffer(value: SchemaId, buffer: ByteBuffer) extends Product with Serializable
- trait SchemaRegistryClient extends Serializable
- trait SchemaRegistryClientFactory extends Serializable
- trait SchemaRegistryClientFactoryWithRegistration extends SchemaRegistryClientFactory
- trait SchemaRegistryClientWithRegistration extends SchemaRegistryClient
- sealed trait SchemaRegistryError extends RuntimeException
- final case class SchemaRegistryUnknownError(message: String, cause: Throwable) extends RuntimeException with SchemaRegistryError with Product with Serializable
- final case class SchemaTopicError(message: String) extends RuntimeException with SchemaRegistryError with Product with Serializable
- final case class SchemaVersionError(message: String) extends RuntimeException with SchemaRegistryError with Product with Serializable
- sealed trait SchemaVersionOption extends AnyRef
-
case class
SchemaWithMetadata extends Product with Serializable
This class holds information that are stored next to schema in registry.
This class holds information that are stored next to schema in registry. It is lightened version of Confluent's SchemaMetadata. We don't want to use their class, because our SchemaRegistryClient is not coupled with concrete schema registry implementation. This class ensures that ParsedSchema will be in the form expected by other mechanisms (see AvroUtils.adjustParsedSchema)
- case class StringSchemaId(value: String) extends SchemaId with Product with Serializable
Value Members
- object LatestSchemaVersion extends SchemaVersionOption with Product with Serializable
- object SchemaId
- object SchemaVersionOption
- object SchemaWithMetadata extends Serializable