如何用Java向kafka發(fā)送json數(shù)據(jù)
問題描述
在網(wǎng)上都只看到一些Java生產(chǎn)STRING類型的消息。 按照Java的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就行了
相關文章：
1. java中返回一個對象，和輸出對像的值，意義在哪兒2. docker網(wǎng)絡端口映射，沒有方便點的操作方法么？3. mysql - 在不允許改動數(shù)據(jù)表的情況下，如何優(yōu)化以varchar格式存儲的時間的比較？4. docker start -a dockername 老是卡住，什么情況？5. css3 - 純css實現(xiàn)點擊特效6. apache web server 怎么限制某一個網(wǎng)站對服務器資源的占用？7. javascript - 關于apply（）與call（）的問題8. docker - 各位電腦上有多少個容器啊？容器一多，自己都搞混了，咋辦呢？9. 安全性測試 - nodejs中如何防m(xù)ySQL注入10. python - pandas dataframe如何對某列的空數(shù)據(jù)位置進行update？update的函數(shù)是自定義的，參數(shù)是同一行的另外兩列數(shù)據(jù)
網(wǎng)公網(wǎng)安備