如何用Java向kafka發(fā)送json數(shù)據(jù)
問(wèn)題描述
在網(wǎng)上都只看到一些Java生產(chǎn)STRING類(lèi)型的消息。 按照J(rèn)ava的producer類(lèi)來(lái)看，是可以自定義發(fā)送消息的類(lèi)型，比如 producer.send(new KeyedMessage<String, HashMap<String , String>>(topic,message); 可是這樣運(yùn)行會(huì)報(bào)錯(cuò)，報(bào)錯(cuò)如下，請(qǐng)求高人解答：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)
問(wèn)題解答
回答1：文檔，序列化成String就行了
相關(guān)文章：
1. 為什么我ping不通我的docker容器呢？？？2. 關(guān)于docker下的nginx壓力測(cè)試3. debian - docker依賴(lài)的aufs-tools源碼哪里可以找到啊？4. angular.js - angular內(nèi)容過(guò)長(zhǎng)展開(kāi)收起效果5. javascript - webpack熱加載配置不生效6. docker start -a dockername 老是卡住，什么情況？7. javascript - js代碼獲取驗(yàn)證碼倒計(jì)時(shí)問(wèn)題8. dockerfile - [docker build image失敗- npm install]9. 主從備份 - 跪求mysql 高可用主從方案10. java - instance method中 static后的<K>是什么意思?
網(wǎng)公網(wǎng)安備