package client
Ordering
- Alphabetic
Visibility
- Public
- All
Type Members
- case class AvroSchemaWithJsonPayload(avroSchema: AvroSchema) extends ParsedSchema with Product with Serializable
-
class
CachedConfluentSchemaRegistryClient extends ConfluentSchemaRegistryClient with LazyLogging
We use there own cache engine because ConfluentCachedClient doesn't cache getLatestSchemaMetadata and getSchemaMetadata
- class CachedConfluentSchemaRegistryClientFactory extends ConfluentSchemaRegistryClientFactory
- trait ConfluentSchemaRegistryClient extends SchemaRegistryClient with LazyLogging
- trait ConfluentSchemaRegistryClientFactory extends SchemaRegistryClientFactory
- class DefaultConfluentSchemaRegistryClient extends ConfluentSchemaRegistryClient
- class MockConfluentSchemaRegistryClientBuilder extends AnyRef
-
class
MockConfluentSchemaRegistryClientFactory extends ConfluentSchemaRegistryClientFactory
MockSchemaRegistryClient must be passed by name, because schemaRegistryMockClient is not serializable.
-
class
MockSchemaRegistryClient extends io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient with LazyLogging
Extended Confluent MockSchemaRegistryClient - base one throws wrong exceptions when version or subject doesn't exist
- case class OpenAPIJsonSchema(schemaString: String) extends JsonSchema with Product with Serializable
- class SchemaRegistryCaches extends LazyLogging
Value Members
- object AvroSchemaWithJsonPayload extends Serializable
- object CachedConfluentSchemaRegistryClientFactory extends CachedConfluentSchemaRegistryClientFactory
- object ConfluentSchemaRegistryClient extends Serializable