在 Java 中使用 Kafka 进行 Spark 结构化流编程

Question

我想要做的是将 json 格式的数据从 kafka 转换为数据帧。我可以通过创建架构并使用 from_json 轻松做到这一点，如下所示：How to use from_json with kafka connect 0.10 and Spark Structured Streaming?

但是无论如何我可以使用 Java 而不是 Scala 来做同样的事情吗？据我所知，java 中没有“from_json”API。

谢谢！

Answer 1

我仍然无法在 Java 中找到 from_json，即使它在 javadoc 中。我觉得这可能是未来对 apache spark 的修复。或者它可能只是火花流不支持java。