Можем ли мы отправить экземпляр класса kafka в Python?

Question

Я хочу отправить экземпляр класса брокеру kafka.

A1 = Axestrack('1087999','2018-05-24')

Здесь Axestrack - это класс Python, а A1 - экземпляр класса Axestrack.
Теперь, как я могу отправить этот экземпляр в kafkaброкер?

Answer 1

Вы можете отправить его как CSV, JSON, Avro или кодировать объект bytes самостоятельно.

Пока вы можете настроить десериализатор для его считывания, не имеет значения, в каком формате вы его отправляете.

Нет «встроенного» сериализатора Python-Kafka (кроме, может быть, pickle)