相当于python中的objectmapper

Question

我想在 python 中序列化我的数据，以便将数据作为生产者发送到 Kafka。:-)还有一个带有 java 的客户端，它将用 java 反序列化消息和kafka.common.serialization什么等价于objectmapper.writeValueAsString().getBytes()在蟒蛇？换句话说，我应该如何使用 python 序列化数据才能从消费者端（java）读取？

Answer 1

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

import json 

...

producer = KafkaProducer(...)

data = {"some":"data"}

producer.send(topic, value=json.dumps(data))