av一区二区在线观看_亚洲男人的天堂网站_日韩亚洲视频_在线成人免费_欧美日韩精品免费观看视频_久草视

您的位置:首頁技術文章
文章詳情頁

如何用Java向kafka發送json數據

瀏覽:107日期:2023-12-05 11:33:32

問題描述

在網上都只看到一些Java生產STRING類型的消息。 按照Java的producer類來看,是可以自定義發送消息的類型,比如 producer.send(new KeyedMessage<String, HashMap<String , String>>(topic,message); 可是這樣運行會報錯,報錯如下,請求高人解答:Exception in thread 'Thread-4' java.lang.ClassCastException: java.util.HashMap cannot be cast to java.lang.String

at kafka.serializer.StringEncoder.toBytes(Encoder.scala:46)at kafka.producer.async.DefaultEventHandler$$anonfun$serialize$1.apply(DefaultEventHandler.scala:130)at kafka.producer.async.DefaultEventHandler$$anonfun$serialize$1.apply(DefaultEventHandler.scala:125)at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33)at scala.collection.mutable.WrappedArray.foreach(WrappedArray.scala:34)at kafka.producer.async.DefaultEventHandler.serialize(DefaultEventHandler.scala:125)at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:52)at kafka.producer.Producer.send(Producer.scala:77)at kafka.javaapi.producer.Producer.send(Producer.scala:33)at com.Model.Producer.kafkaProducer.run(kafkaProducer.java:35)

問題解答

回答1:

文檔,序列化成String就行了

標簽: java
相關文章:
主站蜘蛛池模板: 999视频| 欧美人妇做爰xxxⅹ性高电影 | 久久毛片 | 一级黄在线观看 | 91免费在线视频 | 国产婷婷色综合av蜜臀av | 欧美激情在线播放 | 在线观看av不卡 | 国产一二三区在线 | 欧美日韩国产在线 | 国产精品久久久久久久久久免费看 | 在线观看免费av网 | 亚洲欧美日韩电影 | 久久一区二区三区四区 | 日韩成人精品在线 | 欧美性jizz18性欧美 | 国产一级电影在线观看 | 99av成人精品国语自产拍 | 成人av电影免费在线观看 | 国产成人免费视频网站高清观看视频 | 欧美日韩久 | 亚洲视频网 | 久久国产精99精产国高潮 | 成人精品国产免费网站 | 成人久久久 | 久久国产亚洲 | www.天天干.com | 亚洲国产一区二区三区 | a级片www| 亚洲区一区二区 | 91极品欧美视频 | 日韩欧美视频 | 国产不卡视频在线 | 亚洲欧美日韩一区二区 | 亚洲精品大片 | 国产一区精品在线 | 国产免费自拍 | 午夜小视频在线观看 | 国产精品久久久久久久久久久久冷 | 天天干com | 成人国产精品色哟哟 |