kafka-proto-serde / com.fleshgrinder.kotlin.kafka / NativeSerde / doSerialize

doSerialize

protected fun doSerialize(topic: String, data: T): ByteArray

Overrides BaseSerde.doSerialize

Extending classes must implement this method to convert data of type T to a ByteArray.

Parameters

topic - associated with data

data - to serialize

Exceptions

SerializationException -

Return
ByteArray serialized from data

See Also

serialize