java - 相当于python中的objectmapper

Question

我想在 python 中序列化我的数据，以便将数据发送到 Kafka 作为生产者。 :-)

还有一个使用 java 的客户端，它将使用 java 和 kafka.common.serialization 反序列化消息。

相当于什么

objectmapper.writeValueAsString().getBytes()

在Python中？

换句话说，我应该如何使用 python 序列化数据以便从消费者端(java)读取？

Answer 1

您需要获取一个 dict 对象，然后将 json.dumps 放入 Kafka 记录的值中。

import json 
...

producer = KafkaProducer(...)

data = {"some":"data"}
producer.send(topic, value=json.dumps(data))