-
0 votesanswersviews
JSON作为kafka生成者消息发送并通过spark结构化流式传输-parquet消费
我想知道如何使用scala函数将jSON字符串作为消息发送到kafka主题,并使用spark结构化流中的使用readstream()消费,另存为镶木地板格式 . 目前使用以下代码,但镶木地板文件没有被创建 . 请帮助获取带有数据的镶木地板文件 . 这也作为函数实现,并且需要在集成测试中调用这两个函数 . 发送给Kafka主题的JSON消息 - object kafkaProducer extend...