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]