send Kafka 消息，Map 中 Object 不可解析

来源：4-9 功能开发之Spark和HBase依赖整合

慕沐0177137

2019-12-21

  val map = new util.HashMap[String, Object]()
  map.put("sourceEventTime", sourceEventTime)
  map.put("correlationId", correlationId)
  map.put("merchantOrders", merchantOrder2)

类似这段代码， merchantOrders 就丢了是，自定义的类
需要做特殊处理吗？
return 值是这个格式
"merchantOrders":{“empty”:false,“traversableAgain”:true}

写回答

1回答

Michael_PK

2019-12-21

你直接object估计会有类型转换的丢失，你明确定义一个自定义的类型进去

Spark进阶大数据离线与实时项目实战

大数据生态圈实用框架(Spark/Hbase/Redis/Hadoop)整合应用及调优

705 学习 · 190 问题

查看课程

相似问题

sparkstreming消费kafka算一个消费者吗？

回答 1

kafka消费顺序

回答 1

日志解析，IP信息没找到

回答 3

日志分析业务通用解决方案是啥？

回答 1

消费者数量的问题

回答 1

打开慕课网App查看更多内容