object ConfluentUtils extends LazyLogging
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- ConfluentUtils
- LazyLogging
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final val HeaderSize: Int(5)
- final val IdSize: Int(4)
- final val MagicByte: Int(0)
- final val SchemaProvider: AvroSchemaProvider
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @HotSpotIntrinsicCandidate() @native()
- def convertToAvroSchema(schema: Schema, version: Option[Int] = None): AvroSchema
- def convertToJsonSchema(schema: Schema, version: Option[Int] = None): JsonSchema
- def deserializeSchemaIdAndData[T](payload: Array[Byte], readerWriterSchema: Schema): (SchemaId, T)
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def keySubject(topic: UnspecializedTopicName): String
- def loadAvroSchemaFromResource(path: String): AvroSchema
- def loadJsonSchemaFromResource(path: String): JsonSchema
- lazy val logger: Logger
- Attributes
- protected
- Definition Classes
- LazyLogging
- Annotations
- @transient()
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- def parsePayloadToByteBuffer(payload: Array[Byte]): Validated[IllegalArgumentException, ByteBuffer]
- def readId(bytes: Array[Byte]): SchemaId
- def readIdAndGetBuffer(bytes: Array[Byte]): Validated[IllegalArgumentException, (SchemaId, ByteBuffer)]
- def readIdAndGetBufferUnsafe(bytes: Array[Byte]): (SchemaId, ByteBuffer)
- def serializeContainerToBytesArray(container: GenericContainer, schemaId: SchemaId): Array[Byte]
Based on serializeImpl from io.confluent.kafka.serializers.AbstractKafkaAvroSerializer
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toSchemaWithMetadata(schemaMetadata: SchemaMetadata): SchemaWithMetadata
- def toString(): String
- Definition Classes
- AnyRef → Any
- def topicFromSubject: PartialFunction[String, String]
- def topicSubject(topic: UnspecializedTopicName, isKey: Boolean): String
- def valueSubject(topic: UnspecializedTopicName): String
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- def writeSchemaId(schemaId: SchemaId, stream: OutputStream): Unit
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)