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

HeaderSerializer

fs2.kafka.HeaderSerializer
See theHeaderSerializer companion object
sealed abstract class HeaderSerializer[A]

HeaderSerializer is a functional serializer for Kafka record header values. It's similar to Serializer, except it only has access to the value, and it does not interoperate with the Kafka Serializer interface.

Attributes

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

Members list

Value members

Abstract methods

def serialize(a: A): Array[Byte]
Implicitly added by option

Serializes the specified value of type A into bytes.

Serializes the specified value of type A into bytes.

Attributes

Source
HeaderSerializer.scala
def serialize(a: A): Array[Byte]

Serializes the specified value of type A into bytes.

Serializes the specified value of type A into bytes.

Attributes

Source
HeaderSerializer.scala

Concrete methods

final def contramap[B](f: B => A): HeaderSerializer[B]
Implicitly added by option

Creates a new HeaderSerializer which applies the specified function f on a value of type B, and then serializes the result with this HeaderSerializer.

Creates a new HeaderSerializer which applies the specified function f on a value of type B, and then serializes the result with this HeaderSerializer.

Attributes

Source
HeaderSerializer.scala
final def contramap[B](f: B => A): HeaderSerializer[B]

Creates a new HeaderSerializer which applies the specified function f on a value of type B, and then serializes the result with this HeaderSerializer.

Creates a new HeaderSerializer which applies the specified function f on a value of type B, and then serializes the result with this HeaderSerializer.

Attributes

Source
HeaderSerializer.scala
final def mapBytes(f: (Array[Byte]) => Array[Byte]): HeaderSerializer[A]
Implicitly added by option

Creates a new HeaderSerializer which applies the specified function f on the output bytes of this HeaderSerializer.

Creates a new HeaderSerializer which applies the specified function f on the output bytes of this HeaderSerializer.

Attributes

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

Creates a new HeaderSerializer which applies the specified function f on the output bytes of this HeaderSerializer.

Creates a new HeaderSerializer which applies the specified function f on the output bytes of this HeaderSerializer.

Attributes

Source
HeaderSerializer.scala
final def option: HeaderSerializer[Option[A]]
Implicitly added by option

Creates a new HeaderSerializer which serializes Some values using this HeaderSerializer, and serializes None as null.

Creates a new HeaderSerializer which serializes Some values using this HeaderSerializer, and serializes None as null.

Attributes

Source
HeaderSerializer.scala
final def option: HeaderSerializer[Option[A]]

Creates a new HeaderSerializer which serializes Some values using this HeaderSerializer, and serializes None as null.

Creates a new HeaderSerializer which serializes Some values using this HeaderSerializer, and serializes None as null.

Attributes

Source
HeaderSerializer.scala
Generated with