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
ConfluentSchemaRegistryClient, LazyLogging, SchemaRegistryClient, Serializable, Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. CachedConfluentSchemaRegistryClient
  2. ConfluentSchemaRegistryClient
  3. LazyLogging
  4. SchemaRegistryClient
  5. Serializable
  6. Serializable
  7. AnyRef
  8. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new CachedConfluentSchemaRegistryClient(client: io.confluent.kafka.schemaregistry.client.SchemaRegistryClient, caches: SchemaRegistryCaches)

Value Members

  1. val client: io.confluent.kafka.schemaregistry.client.SchemaRegistryClient
  2. def getAllTopics: Validated[SchemaRegistryError, List[UnspecializedTopicName]]
  3. def getAllVersions(topic: UnspecializedTopicName, isKey: Boolean): Validated[SchemaRegistryError, List[Integer]]
  4. def getByTopicAndVersion(topic: UnspecializedTopicName, version: Int, isKey: Boolean): Validated[SchemaRegistryError, SchemaWithMetadata]
  5. def getFreshSchema(topic: UnspecializedTopicName, version: Option[Int], isKey: Boolean): Validated[SchemaRegistryError, SchemaWithMetadata]
    Definition Classes
    SchemaRegistryClient
  6. 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
    CachedConfluentSchemaRegistryClientSchemaRegistryClient
  7. def getSchemaById(id: SchemaId): SchemaWithMetadata