package schemaregistry

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Package Members

  1. package azure
  2. package confluent
  3. package formatter
  4. package json
  5. package serialization
  6. package universal

Type Members

  1. class BasedOnVersionAvroSchemaDeterminer extends AvroSchemaDeterminer
  2. class ChainedSchemaIdFromMessageExtractor extends SchemaIdFromMessageExtractor
  3. case class ExistingSchemaVersion(version: Int) extends SchemaVersionOption with Product with Serializable
  4. class GenericRecordWithSchemaId extends Record
  5. case class GetSchemaIdArgs(headers: Headers, data: Array[Byte], isKey: Boolean) extends Product with Serializable
  6. case class IntSchemaId(value: Int) extends SchemaId with Product with Serializable
  7. class ParsedSchemaDeterminer extends AnyRef
  8. case class SchemaBasedSerdeProvider(serializationSchemaFactory: KafkaSchemaBasedSerializationSchemaFactory, deserializationSchemaFactory: KafkaSchemaBasedDeserializationSchemaFactory, recordFormatterFactory: RecordFormatterFactory, schemaValidator: SchemaValidator) extends Product with Serializable
  9. final case class SchemaError(message: String) extends RuntimeException with SchemaRegistryError with Product with Serializable
  10. sealed trait SchemaId extends AnyRef
  11. trait SchemaIdFromMessageExtractor extends Serializable
  12. case class SchemaIdWithPositionedBuffer(value: SchemaId, buffer: ByteBuffer) extends Product with Serializable
  13. trait SchemaRegistryClient extends Serializable
  14. trait SchemaRegistryClientFactory extends Serializable
  15. trait SchemaRegistryClientFactoryWithRegistration extends SchemaRegistryClientFactory
  16. trait SchemaRegistryClientWithRegistration extends SchemaRegistryClient
  17. sealed trait SchemaRegistryError extends RuntimeException
  18. final case class SchemaRegistryUnknownError(message: String, cause: Throwable) extends RuntimeException with SchemaRegistryError with Product with Serializable
  19. final case class SchemaTopicError(message: String) extends RuntimeException with SchemaRegistryError with Product with Serializable
  20. final case class SchemaVersionError(message: String) extends RuntimeException with SchemaRegistryError with Product with Serializable
  21. sealed trait SchemaVersionOption extends AnyRef
  22. 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)

  23. case class StringSchemaId(value: String) extends SchemaId with Product with Serializable

Value Members

  1. case object LatestSchemaVersion extends SchemaVersionOption with Product with Serializable
  2. object SchemaId
  3. object SchemaVersionOption
  4. object SchemaWithMetadata extends Serializable

Ungrouped