Class KafkaJsonSerializer<TMessage>

JSON-сериализатор сообщений Kafka

Inheritance

object

KafkaJsonSerializer<TMessage>

Implements

ISerializer<TMessage>

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: NotifyHub.Kafka.Configurations

Assembly: NotifyHub.Kafka.dll

Syntax

public class KafkaJsonSerializer<TMessage> : ISerializer<TMessage>

Type Parameters

Name	Description
TMessage

Methods

Serialize(TMessage, SerializationContext)

Serialize the key or value of a Confluent.Kafka.Message<TKey, TValue> instance.

Declaration

public byte[] Serialize(TMessage data, SerializationContext context)

Parameters

Type	Name	Description
TMessage	data	The value to serialize.
SerializationContext	context	Context relevant to the serialize operation.

Returns

Type	Description
byte[]	The serialized value.

Implements

Confluent.Kafka.ISerializer<T>