Value Members

1.  final def !=(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

2.  final def ##: Int

   Definition Classes

   AnyRef → Any

3.  final def ==(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

4.  def apply[F[_]](implicit F: Sync[F]): Serializer[F, Array[Byte]]

   Alias for Serializer#identity.

5.  def apply[F[_], A](implicit serializer: Serializer[F, A]): Serializer[F, A]
6.  final def asInstanceOf[T0]: T0

   Definition Classes

   Any

7.  def asNull[F[_], A](implicit F: Sync[F]): Serializer[F, A]

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

8.  def clone(): AnyRef

   Attributes

   protected[lang]

   Definition Classes

   AnyRef

   Annotations

   @throws(classOf[java.lang.CloneNotSupportedException]) @native()

9.  def const[F[_], A](bytes: Array[Byte])(implicit F: Sync[F]): Serializer[F, A]

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

10.  implicit def contravariant[T <: KeyOrValue, F[_]]: Contravariant[[γ$0$]GenericSerializer[T, F, γ$0$]]
11.  def delegate[F[_], A](serializer: KafkaSerializer[A])(implicit F: Sync[F]): Serializer[F, A]

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

    Creates a new Serializer which delegates serialization to the specified Kafka Serializer. Note the close and configure functions won't be called for the delegate.
    
    

    It is assumed the delegate serialize function is pure. If it's not pure, then use suspend after delegate, so the impure behaviours can be captured properly.

12.  implicit def double[F[_]](implicit F: Sync[F]): Serializer[F, Double]
13.  def empty[F[_], A](implicit F: Sync[F]): Serializer[F, A]

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

14.  final def eq(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

15.  def equals(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef → Any

16.  def fail[F[_], A](e: Throwable)(implicit F: Sync[F]): Serializer[F, A]

    Creates a new Serializer which always fails serialization with the specified exception e.

17.  def failWith[F[_], A](message: String)(implicit F: Sync[F]): Serializer[F, A]

    Creates a new Serializer which always fails serialization with a SerializationException using the specified message.

18.  def finalize(): Unit

    Attributes

    protected[lang]

    Definition Classes

    AnyRef

    Annotations

    @throws(classOf[java.lang.Throwable])

19.  implicit def float[F[_]](implicit F: Sync[F]): Serializer[F, Float]
20.  final def getClass(): Class[_ <: AnyRef]

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

21.  def hashCode(): Int

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

22.  def headers[F[_], A](f: (Headers) => Serializer[F, A])(implicit F: Sync[F]): Serializer[F, A]

    Creates a new Serializer which can use different Serializers depending on the record headers.

23.  implicit def identity[F[_]](implicit F: Sync[F]): Serializer[F, Array[Byte]]

    The identity Serializer, which does not perform any kind of serialization, simply using the input bytes as the output.

24.  def instance[F[_], A](f: (String, Headers, A) => F[Array[Byte]])(implicit F: Sync[F]): Serializer[F, A]

    Creates a new Serializer from the specified function.

    Creates a new Serializer from the specified function. Use lift instead if the serializer doesn't need access to the Kafka topic name or record headers.

25.  implicit def int[F[_]](implicit F: Sync[F]): Serializer[F, Int]
26.  final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

27.  def lift[F[_], A](f: (A) => F[Array[Byte]])(implicit F: Sync[F]): Serializer[F, A]

    Creates a new Serializer from the specified function, ignoring to which Kafka topic the bytes are going to be sent and any record headers.

    Creates a new Serializer from the specified function, ignoring to which Kafka topic the bytes are going to be sent and any record headers. Use instance instead if the serializer needs access to the Kafka topic name or the record headers.

28.  implicit def long[F[_]](implicit F: Sync[F]): Serializer[F, Long]
29.  final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

30.  final def notify(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

31.  final def notifyAll(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

32.  implicit def option[T <: KeyOrValue, F[_], A](implicit serializer: GenericSerializer[T, F, A]): GenericSerializer[T, F, Option[A]]

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

33.  implicit def resource[T <: KeyOrValue, F[_], A](implicit ser: GenericSerializer[T, F, A]): Resource[F, GenericSerializer[T, F, A]]
34.  implicit def short[F[_]](implicit F: Sync[F]): Serializer[F, Short]
35.  implicit def string[F[_]](implicit F: Sync[F]): Serializer[F, String]
36.  def string[F[_]](charset: Charset)(implicit F: Sync[F]): Serializer[F, String]

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

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

37.  final def synchronized[T0](arg0: => T0): T0

    Definition Classes

    AnyRef

38.  def toString(): String

    Definition Classes

    AnyRef → Any

39.  def topic[T <: KeyOrValue, F[_], A](f: PartialFunction[String, GenericSerializer[T, F, A]])(implicit F: Sync[F]): GenericSerializer[T, F, A]

    Creates a new Serializer which can use different Serializers depending on the Kafka topic name to which the bytes are going to be sent.

40.  implicit def unit[F[_]](implicit F: Sync[F]): Serializer[F, Unit]
41.  implicit def uuid[F[_]](implicit F: Sync[F]): Serializer[F, UUID]
42.  def uuid[F[_]](charset: Charset)(implicit F: Sync[F]): Serializer[F, UUID]

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

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

43.  final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws(classOf[java.lang.InterruptedException])

44.  final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws(classOf[java.lang.InterruptedException])

45.  final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws(classOf[java.lang.InterruptedException]) @native()