Блог

Я отправляю сообщения от производителя Kafka потребителю на python.

В Producer я отправляю данные следующим образом:

 producer.send(topicName,str.encode( message_data))
 

И в получении потребителем данных с:

 for msg in consumer:
   # print("Message from Producer on Topic - " msg.topic ":"  msg.value.decode())
 

Здесь данные представлены в байтах.
Аналогично, мне нужно отправить данные в разных типах данных и сравнить производительность.Как я могу это сделать?

Kafka всегда хранит данные в байтах. Вы можете использовать любой тип данных, который вы хотите, например, вы могли бы использовать pickle или json (хотя это все равно будет строка) вместо простого кодирования строковой переменной

Некоторые библиотеки Kafka Python предоставляют функцию сериализатора, а не вы явно обрабатываете сериализацию между клиентами