pulsar.functions.serde

module documentation
(source)

SerDe defines the interface for serialization/deserialization.

Everytime a message is read from pulsar topic, the serde is invoked to serialize the bytes into an object before invoking the process method. Anytime a python object needs to be written back to pulsar, it is serialized into bytes before writing.

Class IdentitySerDe Simple Serde that just conversion to string and back
Class PickleSerDe Pickle based serializer
Class SerDe Interface for Serialization/Deserialization