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

您的位置:首頁技術(shù)文章
文章詳情頁

如何用Java向kafka發(fā)送json數(shù)據(jù)

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

問題描述

在網(wǎng)上都只看到一些Java生產(chǎn)STRING類型的消息。 按照J(rèn)ava的producer類來看,是可以自定義發(fā)送消息的類型,比如 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就行了

標(biāo)簽: java
相關(guān)文章:
主站蜘蛛池模板: 九色视频网站 | 国产二区在线播放 | 亚州av | 范冰冰一级做a爰片久久毛片 | 日韩中文一区二区三区 | 久久久一区二区三区 | 国产日韩久久 | 中文字幕在线观看一区二区 | 欧美国产视频 | 99精品电影 | 中文字幕亚洲在线 | 爱爱视频网 | 欧美精品日韩精品国产精品 | 一区福利视频 | 网站黄色在线免费观看 | 欧美亚洲在线 | 羞羞在线观看视频 | 91大神在线资源观看无广告 | 久久男人| 国产一区久久 | 久久久久国产精品午夜一区 | 日韩成人精品一区 | 一区二区中文字幕 | 欧美精品一区二区三区四区五区 | 成年人在线观看视频 | 国产精品久久久乱弄 | 亚洲先锋影音 | 三级在线免费观看 | www.国产精| 一区二区三区四区国产 | 亚洲综合免费 | 欧美男男videos | 国产91丝袜在线18 | 亚洲人成人一区二区在线观看 | 亚洲国产欧美一区二区三区久久 | 视频一区在线播放 | 国产成在线观看免费视频 | 久久精品一区 | 91精品久久久久久久久 | 久久精品中文 | 在线视频 亚洲 |