我想在 python 中序列化我的数据,以便将数据发送到 Kafka 作为生产者。 :-)
还有一个使用 java 的客户端,它将使用 java 和 kafka.common.serialization
反序列化消息。
相当于什么
objectmapper.writeValueAsString().getBytes()
在Python中?
换句话说,我应该如何使用 python 序列化数据以便从消费者端(java)读取?
最佳答案
您需要获取一个 dict
对象,然后将 json.dumps
放入 Kafka 记录的值中。
import json
...
producer = KafkaProducer(...)
data = {"some":"data"}
producer.send(topic, value=json.dumps(data))
关于java - 相当于python中的objectmapper,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/57373653/