object ConfluentUtils extends LazyLogging

Linear Supertypes
LazyLogging, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ConfluentUtils
  2. LazyLogging
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Value Members

  1. final val HeaderSize: Int
  2. final val IdSize: Int(4)
  3. final val MagicByte: Int(0)
  4. final val SchemaProvider: AvroSchemaProvider
  5. def convertToAvroSchema(schema: Schema, version: Option[Int] = None): AvroSchema
  6. def convertToJsonSchema(schema: Schema, version: Option[Int] = None): JsonSchema
  7. def deserializeSchemaIdAndData[T](payload: Array[Byte], readerWriterSchema: Schema): (Int, T)
  8. def extractSchema(parsedSchema: ParsedSchema): Schema
  9. def keySubject(topic: String): String
  10. def parsePayloadToByteBuffer(payload: Array[Byte]): Validated[IllegalArgumentException, ByteBuffer]
  11. def readId(bytes: Array[Byte]): Int
  12. def readIdAndGetBuffer(bytes: Array[Byte]): Validated[IllegalArgumentException, (Int, ByteBuffer)]
  13. def readIdAndGetBufferUnsafe(bytes: Array[Byte]): (Int, ByteBuffer)
  14. def serializeContainerToBytesArray(container: GenericContainer, schemaId: Int): Array[Byte]

    Based on serializeImpl from io.confluent.kafka.serializers.AbstractKafkaAvroSerializer

  15. def topicFromSubject: PartialFunction[String, String]
  16. def topicSubject(topic: String, isKey: Boolean): String
  17. def valueSubject(topic: String): String
  18. def writeSchemaId(schemaId: Int, stream: OutputStream): Unit