fs2-kafka
3.5.1
API
Generated with
fs2-kafka/fs2.kafka/HeaderSerializer

HeaderSerializer

fs2.kafka.HeaderSerializer
See theHeaderSerializer companion class
object HeaderSerializer

Attributes

Companion
class
Source
HeaderSerializer.scala
Graph
Supertypes
class Object
trait Matchable
class Any
Self type

Members list

Value members

Concrete methods

def apply[A](implicit serializer: HeaderSerializer[A]): HeaderSerializer[A]

Attributes

Source
HeaderSerializer.scala
def asNull[A]: HeaderSerializer[A]

Creates a new HeaderSerializer which serializes all values of type A as null.

Creates a new HeaderSerializer which serializes all values of type A as null.

Attributes

Source
HeaderSerializer.scala
def const[A](bytes: Array[Byte]): HeaderSerializer[A]

Creates a new HeaderSerializer which serializes all values of type A to the specified bytes.

Creates a new HeaderSerializer which serializes all values of type A to the specified bytes.

Attributes

Source
HeaderSerializer.scala
def delegate[A](serializer: Serializer[A]): HeaderSerializer[A]

Creates a new HeaderSerializer which delegates serialization to the specified Kafka Serializer.

Creates a new HeaderSerializer which delegates serialization to the specified Kafka Serializer. Note that the close and configure functions won't be called for the delegate. Also, the topic is an empty String and no headers are provided.

Attributes

Source
HeaderSerializer.scala
def empty[A]: HeaderSerializer[A]

Creates a new HeaderSerializer which serializes all values of type A as the empty Array[Byte].

Creates a new HeaderSerializer which serializes all values of type A as the empty Array[Byte].

Attributes

Source
HeaderSerializer.scala
def instance[A](f: A => Array[Byte]): HeaderSerializer[A]

Creates a new HeaderSerializer from the specified function.

Creates a new HeaderSerializer from the specified function.

Attributes

Source
HeaderSerializer.scala
def string(charset: Charset): HeaderSerializer[String]

Creates a new HeaderSerializer which serializes String values using the specified Charset.

Creates a new HeaderSerializer which serializes String values using the specified Charset. Note that the default String serializer uses UTF-8.

Attributes

Source
HeaderSerializer.scala
def uuid(charset: Charset): HeaderSerializer[UUID]

Creates a new HeaderSerializer which serializes UUID values as Strings with the specified Charset.

Creates a new HeaderSerializer which serializes UUID values as Strings with the specified Charset. Note that the default UUID serializer uses UTF-8.

Attributes

Source
HeaderSerializer.scala

Implicits

Implicits

implicit val double: HeaderSerializer[Double]

Attributes

Source
HeaderSerializer.scala
implicit val float: HeaderSerializer[Float]

Attributes

Source
HeaderSerializer.scala
implicit val identity: HeaderSerializer[Array[Byte]]

The identity HeaderSerializer, which does not perform serialization, simply using the input bytes as the output.

The identity HeaderSerializer, which does not perform serialization, simply using the input bytes as the output.

Attributes

Source
HeaderSerializer.scala
implicit val int: HeaderSerializer[Int]

Attributes

Source
HeaderSerializer.scala
implicit val long: HeaderSerializer[Long]

Attributes

Source
HeaderSerializer.scala
implicit def option[A](implicit serializer: HeaderSerializer[A]): HeaderSerializer[Option[A]]

The option HeaderSerializer serializes None as null, and serializes Some values using the serializer for type A.

The option HeaderSerializer serializes None as null, and serializes Some values using the serializer for type A.

Attributes

Source
HeaderSerializer.scala
implicit val short: HeaderSerializer[Short]

Attributes

Source
HeaderSerializer.scala
implicit val string: HeaderSerializer[String]

Attributes

Source
HeaderSerializer.scala
implicit val unit: HeaderSerializer[Unit]

Attributes

Source
HeaderSerializer.scala
implicit val uuid: HeaderSerializer[UUID]

Attributes

Source
HeaderSerializer.scala
Generated with