Kakfa的火花流

Question

我试图使用Kafka作为我的来源来做火花流，但是我得到了如下错误：

线程"main“java.lang.NoSuchMethodError: java.lang.NoSuchMethodError中的异常

我的Kafka版本是Kafka_2.11-0.11，我在Scala2.11中使用了Spark2.0.0。我无法在maven或任何地方找到上述兼容的jar。上面提到的jar版本较低，但没有上述配置。我使用SCALA和scala库运行代码，作为2.11.8。这段代码成功运行了一次，但不知道在重新运行后，代码会抛出上面的错误。

如果你们都能分享你的想法并提供一些解决方案，这将是非常有帮助的。谢谢并提前。请回答!！

希望得到答案！

Answer 1

我相信问题是你没有一个主要的方法。某些语言(如java和c)要求您有一个主方法，并将您的代码放入其中。这就是为什么上面写着"main": no such method"。因此，除了导入语句、函数等之外，您还需要为所有内容创建一个主方法。希望这会有所帮助。