Packages

c

com.avsystem.commons.kafka

SerdeRegistry

class SerdeRegistry[T] extends AbstractDeserializer[T]

Linear Supertypes
AbstractDeserializer[T], Deserializer[T], Closeable, AutoCloseable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SerdeRegistry
  2. AbstractDeserializer
  3. Deserializer
  4. Closeable
  5. AutoCloseable
  6. AnyRef
  7. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new SerdeRegistry(codecs: Map[Byte, GenCodec[_ <: T]])

Value Members

  1. def close(): Unit
    Definition Classes
    AbstractDeserializer → Deserializer → Closeable → AutoCloseable
  2. def configure(configs: commons.JMap[String, _], isKey: Boolean): Unit
    Definition Classes
    AbstractDeserializer → Deserializer
  3. def deserialize(topic: String, data: Array[Byte]): T
    Definition Classes
    SerdeRegistry → Deserializer
  4. def deserialize(arg0: String, arg1: Headers, arg2: Array[Byte]): T
    Definition Classes
    Deserializer