c
pl.touk.nussknacker.engine.schemedkafka.schemaregistry.confluent.client
CachedConfluentSchemaRegistryClient
class CachedConfluentSchemaRegistryClient extends ConfluentSchemaRegistryClient with LazyLogging
We use there own cache engine because ConfluentCachedClient doesn't cache getLatestSchemaMetadata and getSchemaMetadata
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- CachedConfluentSchemaRegistryClient
- ConfluentSchemaRegistryClient
- LazyLogging
- SchemaRegistryClient
- Serializable
- Serializable
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- All
Instance Constructors
- new CachedConfluentSchemaRegistryClient(client: io.confluent.kafka.schemaregistry.client.SchemaRegistryClient, caches: SchemaRegistryCaches)
Value Members
-
val
client: io.confluent.kafka.schemaregistry.client.SchemaRegistryClient
- Definition Classes
- CachedConfluentSchemaRegistryClient → ConfluentSchemaRegistryClient
-
def
getAllTopics: Validated[SchemaRegistryError, List[UnspecializedTopicName]]
- Definition Classes
- CachedConfluentSchemaRegistryClient → SchemaRegistryClient
-
def
getAllVersions(topic: UnspecializedTopicName, isKey: Boolean): Validated[SchemaRegistryError, List[Integer]]
- Definition Classes
- CachedConfluentSchemaRegistryClient → SchemaRegistryClient
-
def
getByTopicAndVersion(topic: UnspecializedTopicName, version: Int, isKey: Boolean): Validated[SchemaRegistryError, SchemaWithMetadata]
- Definition Classes
- CachedConfluentSchemaRegistryClient → SchemaRegistryClient
-
def
getFreshSchema(topic: UnspecializedTopicName, version: Option[Int], isKey: Boolean): Validated[SchemaRegistryError, SchemaWithMetadata]
- Definition Classes
- SchemaRegistryClient
-
def
getLatestFreshSchema(topic: UnspecializedTopicName, isKey: Boolean): Validated[SchemaRegistryError, SchemaWithMetadata]
Latest fresh schema by topic - it should be always fresh schema
Latest fresh schema by topic - it should be always fresh schema
- Definition Classes
- CachedConfluentSchemaRegistryClient → SchemaRegistryClient
-
def
getSchemaById(id: SchemaId): SchemaWithMetadata
- Definition Classes
- CachedConfluentSchemaRegistryClient → SchemaRegistryClient