Class KafkaDestination<TInput>.DefaultRowSerializer
Inheritance
KafkaDestination<TInput>.DefaultRowSerializer
Implements
ISerializer<TInput>
Namespace: ETLBox.Apache.Kafka.KafkaDestination`1
Assembly: ETLBox.Apache.Kafka.dll
Syntax#
Methods
Serialize(TInput, SerializationContext)#
Serialize the key or value of a Confluent.Kafka.Message<TKey, TValue>
instance.
Declaration
Parameters
Type | Name | Description |
---|
TInput | 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>