pulsar.functions.serde

module documentation

(source)

SerDe defines the interface for serialization/deserialization.

Every time 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