KafkaDestination<TInput>.DefaultRowSerializer

Class KafkaDestination<TInput>.DefaultRowSerializer

Inheritance
KafkaDestination<TInput>.DefaultRowSerializer
Implements
ISerializer<TInput>
Namespace: ETLBox.Apache.Kafka.KafkaDestination`1
Assembly: ETLBox.Apache.Kafka.dll
Syntax
    public class KafkaDestination<TInput>.DefaultRowSerializer : ISerializer<TInput>

Methods

Serialize(TInput, SerializationContext)

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

Declaration
    public byte[] Serialize(TInput data, SerializationContext context)
Parameters
TypeNameDescription
TInputdata

The value to serialize.

SerializationContextcontext

Context relevant to the serialize operation.

Returns
TypeDescription
byte[]

The serialized value.

Implements

Confluent.Kafka.ISerializer<T>