Packages

c

com.avsystem.commons.kafka

VersionedSerializer

class VersionedSerializer[T] extends AbstractSerializer[T]

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

Instance Constructors

  1. new VersionedSerializer(version: Byte)(implicit codec: GenCodec[T])

Value Members

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