亚洲在线久爱草,狠狠天天香蕉网,天天搞日日干久草,伊人亚洲日本欧美

為了賬號安全,請及時綁定郵箱和手機立即綁定
已解決430363個問題,去搜搜看,總會有你想問的

相當于python中的objectmapper

相當于python中的objectmapper

慕碼人8056858 2022-04-24 18:51:10
我想在 python 中序列化我的數據,以便將數據作為生產者發送到 Kafka。:-)還有一個帶有 java 的客戶端,它將用 java 反序列化消息和kafka.common.serialization什么等價于objectmapper.writeValueAsString().getBytes()在蟒蛇?換句話說,我應該如何使用 python 序列化數據才能從消費者端(java)讀???
查看完整描述

1 回答

?
繁花不似錦

TA貢獻1851條經驗 獲得超4個贊

您需要獲取一個dict對象,然后json.dumps將其放入 Kafka 記錄的值中。


import json 

...


producer = KafkaProducer(...)


data = {"some":"data"}

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


查看完整回答
反對 回復 2022-04-24
  • 1 回答
  • 0 關注
  • 133 瀏覽
慕課專欄
更多

添加回答

舉報

0/150
提交
取消
微信客服

購課補貼
聯系客服咨詢優惠詳情

幫助反饋 APP下載

慕課網APP
您的移動學習伙伴

公眾號

掃描二維碼
關注慕課網微信公眾號