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

GenericSerializer

fs2.kafka.GenericSerializer
See theGenericSerializer companion object
sealed abstract class GenericSerializer[-T <: KeyOrValue, F[_], A]

Attributes

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

Members list

Value members

Abstract methods

def contramap[B](f: B => A): GenericSerializer[T, F, B]
Implicitly added by option

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

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

Attributes

Source
Serializer.scala
def contramap[B](f: B => A): GenericSerializer[T, F, B]

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

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

Attributes

Source
Serializer.scala
def mapBytes(f: (Array[Byte]) => Array[Byte]): GenericSerializer[T, F, A]
Implicitly added by option

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

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

Attributes

Source
Serializer.scala
def mapBytes(f: (Array[Byte]) => Array[Byte]): GenericSerializer[T, F, A]

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

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

Attributes

Source
Serializer.scala
def option: GenericSerializer[T, F, Option[A]]
Implicitly added by option

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

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

Attributes

Source
Serializer.scala
def option: GenericSerializer[T, F, Option[A]]

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

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

Attributes

Source
Serializer.scala
def serialize(topic: String, headers: Headers, a: A): F[Array[Byte]]
Implicitly added by option

Attempts to serialize the specified value of type A into bytes.

Attempts to serialize the specified value of type A into bytes. The Kafka topic name, to which the serialized bytes are going to be sent, and record headers are available.

Attributes

Source
Serializer.scala
def serialize(topic: String, headers: Headers, a: A): F[Array[Byte]]

Attempts to serialize the specified value of type A into bytes.

Attempts to serialize the specified value of type A into bytes. The Kafka topic name, to which the serialized bytes are going to be sent, and record headers are available.

Attributes

Source
Serializer.scala
def suspend: Serializer[F, A]
Implicitly added by option

Creates a new Serializer which suspends serialization, capturing any impure behaviours of this Serializer.

Creates a new Serializer which suspends serialization, capturing any impure behaviours of this Serializer.

Attributes

Source
Serializer.scala
def suspend: Serializer[F, A]

Creates a new Serializer which suspends serialization, capturing any impure behaviours of this Serializer.

Creates a new Serializer which suspends serialization, capturing any impure behaviours of this Serializer.

Attributes

Source
Serializer.scala
Generated with