如何用Java向kafka发送json数据 报错-问答-阿里云开发者社区-阿里云

开发者社区> 问答> 正文
阿里云
为了无法计算的价值
打开APP
阿里云APP内打开

如何用Java向kafka发送json数据 报错

2020-05-25 15:58:10 1278 1

"

在网上都只看到一些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)
" image.png

取消 提交回答
全部回答(1)
  • 因为相信,所以看见。
    2020-05-25 22:53:30

    文档,序列化成String就行了

    ![image.png](https://ucc.alicdn.com/pic/developer-ecology/5bbafc4e81f741a8ae06fcd77d934183.png)
    0 0
相关问答

0

回答

使用java获取某个JSON数据中的某个key对应的value性能最优的做法是什么?

2021-11-06 19:45:34 118浏览量 回答数 0

0

回答

请问使用java获取某个JSON数据中的某个key对应的value性能最优的做法是什么?

2021-11-06 22:47:59 160浏览量 回答数 0

0

回答

请问使用java获取JSON数据某个key的值的最优性能的做法是什么?

2021-11-07 00:10:23 128浏览量 回答数 0

0

回答

请问java性能问题:如何优化向HashMap插入元素的速度?

2021-11-12 17:18:18 126浏览量 回答数 0

0

回答

请问java中使用BigDecimal计算操作性能最优的做法是什么?

2021-11-07 15:42:19 198浏览量 回答数 0

1

回答

java性能问题:有没有比较字符串是否相等的最快方法?

2021-11-06 16:21:40 153浏览量 回答数 1

0

回答

您好java性能问题:有没有比较字符串是否相等的最快方法?

2021-11-07 00:39:14 132浏览量 回答数 0

1

回答

java性能问题:如何优化向HashMap插入元素的速度?

2021-11-06 15:41:34 200浏览量 回答数 1

0

回答

请问java中常用的性能调优诊断工具都有哪些,请帮忙提供一下?

2021-11-06 22:35:44 78浏览量 回答数 0

1

回答

java中常用的性能调优诊断工具都有哪些,请帮忙提供一下?

2021-11-06 10:24:39 146浏览量 回答数 1
+关注
因为相信,所以看见。
阿里,我所有的向往
0
文章
1438
问答
问答排行榜
最热
最新
相关电子书
更多
低代码开发师(初级)实战教程
立即下载
阿里巴巴DevOps 最佳实践手册
立即下载
冬季实战营第三期:MySQL数据库进阶实战
立即下载