kafka

serializer

package serializer

Visibility
  1. Public
  2. All

Type Members

  1. trait Decoder[T] extends AnyRef

    A decoder is a method of turning byte arrays into objects.

    A decoder is a method of turning byte arrays into objects. An implementation is required to provide a constructor that takes a VerifiableProperties instance.

  2. class DefaultDecoder extends Decoder[Array[Byte]]

    The default implementation does nothing, just returns the same byte array it takes in.

  3. class DefaultEncoder extends Encoder[Array[Byte]]

    The default implementation is a no-op, it just returns the same array it takes in

  4. trait Encoder[T] extends AnyRef

    An encoder is a method of turning objects into byte arrays.

    An encoder is a method of turning objects into byte arrays. An implementation is required to provide a constructor that takes a VerifiableProperties instance.

  5. class NullEncoder[T] extends Encoder[T]

  6. class StringDecoder extends Decoder[String]

    The string encoder translates strings into bytes.

    The string encoder translates strings into bytes. It uses UTF8 by default but takes an optional property serializer.encoding to control this.

  7. class StringEncoder extends Encoder[String]

    The string encoder takes an optional parameter serializer.

    The string encoder takes an optional parameter serializer.encoding which controls the character set used in encoding the string into bytes.

Ungrouped