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

Linear Supertypes
LazyLogging, io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient, io.confluent.kafka.schemaregistry.client.SchemaRegistryClient, SchemaVersionFetcher, Closeable, AutoCloseable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. MockSchemaRegistryClient
  2. LazyLogging
  3. MockSchemaRegistryClient
  4. SchemaRegistryClient
  5. SchemaVersionFetcher
  6. Closeable
  7. AutoCloseable
  8. AnyRef
  9. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new MockSchemaRegistryClient()

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @HotSpotIntrinsicCandidate() @native()
  6. def close(): Unit
    Definition Classes
    SchemaRegistryClient → Closeable → AutoCloseable
    Annotations
    @throws(classOf[java.io.IOException])
  7. def deleteCompatibility(arg0: String): Unit
    Definition Classes
    SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  8. def deleteConfig(arg0: String): Unit
    Definition Classes
    SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  9. def deleteMode(arg0: String): Unit
    Definition Classes
    SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  10. def deleteSchemaVersion(arg0: Map[String, String], arg1: String, arg2: String, arg3: Boolean): Integer
    Definition Classes
    MockSchemaRegistryClient → SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  11. def deleteSchemaVersion(arg0: String, arg1: String, arg2: Boolean): Integer
    Definition Classes
    MockSchemaRegistryClient → SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  12. def deleteSchemaVersion(arg0: Map[String, String], arg1: String, arg2: String): Integer
    Definition Classes
    SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  13. def deleteSchemaVersion(arg0: String, arg1: String): Integer
    Definition Classes
    SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  14. def deleteSubject(arg0: Map[String, String], arg1: String, arg2: Boolean): List[Integer]
    Definition Classes
    MockSchemaRegistryClient → SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  15. def deleteSubject(arg0: String, arg1: Boolean): List[Integer]
    Definition Classes
    MockSchemaRegistryClient → SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  16. def deleteSubject(arg0: Map[String, String], arg1: String): List[Integer]
    Definition Classes
    SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  17. def deleteSubject(arg0: String): List[Integer]
    Definition Classes
    SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  18. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  19. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  20. def getAllSubjects(): Collection[String]
    Definition Classes
    MockSchemaRegistryClient → SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  21. def getAllSubjects(arg0: Boolean): Collection[String]
    Definition Classes
    SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  22. def getAllSubjectsById(arg0: Int): Collection[String]
    Definition Classes
    MockSchemaRegistryClient → SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  23. def getAllSubjectsByPrefix(arg0: String): Collection[String]
    Definition Classes
    MockSchemaRegistryClient → SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  24. def getAllVersions(subject: String): List[Integer]
    Definition Classes
    MockSchemaRegistryClient → MockSchemaRegistryClient → SchemaRegistryClient
  25. def getAllVersions(arg0: String, arg1: Boolean): List[Integer]
    Definition Classes
    SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  26. def getAllVersionsById(arg0: Int): Collection[SubjectVersion]
    Definition Classes
    MockSchemaRegistryClient → SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  27. def getByVersion(arg0: String, arg1: Int, arg2: Boolean): Schema
    Definition Classes
    MockSchemaRegistryClient → SchemaRegistryClient → SchemaVersionFetcher
  28. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  29. def getCompatibility(arg0: String): String
    Definition Classes
    SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  30. def getConfig(arg0: String): Config
    Definition Classes
    MockSchemaRegistryClient → SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  31. def getId(arg0: String, arg1: ParsedSchema, arg2: Boolean): Int
    Definition Classes
    MockSchemaRegistryClient → SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  32. def getId(arg0: String, arg1: ParsedSchema): Int
    Definition Classes
    MockSchemaRegistryClient → SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  33. def getLatestSchemaMetadata(subject: String): SchemaMetadata
    Definition Classes
    MockSchemaRegistryClient → MockSchemaRegistryClient → SchemaRegistryClient
  34. def getLatestWithMetadata(arg0: String, arg1: Map[String, String], arg2: Boolean): SchemaMetadata
    Definition Classes
    MockSchemaRegistryClient → SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  35. def getMode(arg0: String): String
    Definition Classes
    MockSchemaRegistryClient → SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  36. def getMode(): String
    Definition Classes
    MockSchemaRegistryClient → SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  37. def getSchemaById(arg0: Int): ParsedSchema
    Definition Classes
    MockSchemaRegistryClient → SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  38. def getSchemaBySubjectAndId(arg0: String, arg1: Int): ParsedSchema
    Definition Classes
    MockSchemaRegistryClient → SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  39. def getSchemaMetadata(subject: String, version: Int): SchemaMetadata
    Definition Classes
    MockSchemaRegistryClient → MockSchemaRegistryClient → SchemaRegistryClient
  40. def getSchemaMetadata(arg0: String, arg1: Int, arg2: Boolean): SchemaMetadata
    Definition Classes
    MockSchemaRegistryClient → SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  41. def getSchemas(arg0: String, arg1: Boolean, arg2: Boolean): List[ParsedSchema]
    Definition Classes
    MockSchemaRegistryClient → SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  42. def getVersion(arg0: String, arg1: ParsedSchema, arg2: Boolean): Int
    Definition Classes
    MockSchemaRegistryClient → SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  43. def getVersion(arg0: String, arg1: ParsedSchema): Int
    Definition Classes
    MockSchemaRegistryClient → SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  44. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  45. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  46. lazy val logger: Logger
    Attributes
    protected
    Definition Classes
    LazyLogging
    Annotations
    @transient()
  47. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  48. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  49. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  50. def parseSchema(arg0: Schema): Optional[ParsedSchema]
    Definition Classes
    MockSchemaRegistryClient → SchemaRegistryClient
  51. def parseSchema(arg0: String, arg1: String, arg2: List[SchemaReference]): Optional[ParsedSchema]
    Definition Classes
    MockSchemaRegistryClient → SchemaRegistryClient
  52. def parseSchema(arg0: String, arg1: String, arg2: List[SchemaReference], arg3: Metadata, arg4: RuleSet): Optional[ParsedSchema]
    Definition Classes
    SchemaRegistryClient
  53. def register(arg0: String, arg1: ParsedSchema, arg2: Int, arg3: Int): Int
    Definition Classes
    MockSchemaRegistryClient → SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  54. def register(arg0: String, arg1: ParsedSchema, arg2: Boolean): Int
    Definition Classes
    MockSchemaRegistryClient → SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  55. def register(arg0: String, arg1: ParsedSchema): Int
    Definition Classes
    MockSchemaRegistryClient → SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  56. def registerWithResponse(arg0: String, arg1: ParsedSchema, arg2: Boolean): RegisterSchemaResponse
    Definition Classes
    MockSchemaRegistryClient → SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  57. def reset(): Unit
    Definition Classes
    MockSchemaRegistryClient → SchemaRegistryClient
  58. def setMode(arg0: String, arg1: String, arg2: Boolean): String
    Definition Classes
    MockSchemaRegistryClient → SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  59. def setMode(arg0: String, arg1: String): String
    Definition Classes
    MockSchemaRegistryClient → SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  60. def setMode(arg0: String): String
    Definition Classes
    MockSchemaRegistryClient → SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  61. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  62. def tenant(): String
    Definition Classes
    SchemaRegistryClient → SchemaVersionFetcher
  63. def testCompatibility(arg0: String, arg1: ParsedSchema): Boolean
    Definition Classes
    MockSchemaRegistryClient → SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  64. def testCompatibilityVerbose(arg0: String, arg1: ParsedSchema): List[String]
    Definition Classes
    MockSchemaRegistryClient → SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  65. def testCompatibilityVerbose(arg0: String, arg1: ParsedSchema, arg2: Boolean): List[String]
    Definition Classes
    SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  66. def ticker(): Ticker
    Definition Classes
    SchemaRegistryClient
  67. def toString(): String
    Definition Classes
    AnyRef → Any
  68. def updateCompatibility(arg0: String, arg1: String): String
    Definition Classes
    SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  69. def updateConfig(arg0: String, arg1: Config): Config
    Definition Classes
    MockSchemaRegistryClient → SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException])
  70. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  71. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  72. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

    (Since version 9)

  2. def getByID(arg0: Int): Schema
    Definition Classes
    SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException]) @Deprecated
    Deprecated
  3. def getById(arg0: Int): Schema
    Definition Classes
    SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException]) @Deprecated
    Deprecated
  4. def getBySubjectAndID(arg0: String, arg1: Int): Schema
    Definition Classes
    SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException]) @Deprecated
    Deprecated
  5. def getBySubjectAndId(arg0: String, arg1: Int): Schema
    Definition Classes
    SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException]) @Deprecated
    Deprecated
  6. def getId(arg0: String, arg1: Schema): Int
    Definition Classes
    SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException]) @Deprecated
    Deprecated
  7. def getVersion(arg0: String, arg1: Schema): Int
    Definition Classes
    SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException]) @Deprecated
    Deprecated
  8. def register(arg0: String, arg1: Schema, arg2: Int, arg3: Int): Int
    Definition Classes
    SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException]) @Deprecated
    Deprecated
  9. def register(arg0: String, arg1: Schema): Int
    Definition Classes
    SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException]) @Deprecated
    Deprecated
  10. def testCompatibility(arg0: String, arg1: Schema): Boolean
    Definition Classes
    SchemaRegistryClient
    Annotations
    @throws(classOf[java.io.IOException]) @throws(classOf[io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException]) @Deprecated
    Deprecated

Inherited from LazyLogging

Inherited from io.confluent.kafka.schemaregistry.client.MockSchemaRegistryClient

Inherited from io.confluent.kafka.schemaregistry.client.SchemaRegistryClient

Inherited from SchemaVersionFetcher

Inherited from Closeable

Inherited from AutoCloseable

Inherited from AnyRef

Inherited from Any

Ungrouped