Serializer

class kafka.Serializer[source]
close()[source]
abstract serialize(topic: str, headers: List[Tuple[str, bytes]], data: Any)[source]
class kafka.Deserializer[source]
close()[source]
abstract deserialize(topic: str, headers: List[Tuple[str, bytes]], data: bytes)[source]
class kafka.JsonSerializer[source]
deserialize(topic, headers, data)[source]
serialize(topic, headers, data)[source]
class kafka.DefaultSerializer(encoding='utf-8')[source]
deserialize(topic, headers, data)[source]
serialize(topic, headers, data)[source]