如何用Java向kafka發送json數據
問題描述
在網上都只看到一些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就行了
相關文章：
1. mac里的docker如何命令行開啟呢？2. 為什么我ping不通我的docker容器呢？？？3. nignx - docker內nginx 80端口被占用4. 關docker hub上有些鏡像的tag被標記““This image has vulnerabilities””5. docker容器呢SSH為什么連不通呢？6. Docker for Mac 創建的dnsmasq容器連不上/不工作的問題7. angular.js使用$resource服務把數據存入mongodb的問題。8. javascript - 最近用echarts做統計圖時遇到兩個問題！！9. docker 下面創建的IMAGE 他們的 ID 一樣？這個是怎么回事？？？？10. docker gitlab 如何git clone？
網公網安備