我正在使用springboot、kafka和spark进行一个小项目。到目前为止，我已经能够创建一个Kafka生产者在一个项目和SparkKafka直接流作为消费者。
我能够看到信息传递，事情似乎按预期进行。但是，我在运行使用者的项目上有一个rest端点。无论何时禁用直接流，端点都可以正常工作。然而，当我有流运行， Postman 说没有回应。我在服务器日志中也没有看到任何表示曾经收到过请求的信息。
spark消费者在项目启动时由一个bean启动。这是正常的服务器吗localhost:8080 from 正在启动？
1条答案
按热度按时间s5a0g9ez1#
最初，我是通过将streamingcontext注解为bean来启动它的。相反，我让应用程序实现commandlinerunner，在重写的run方法中，我调用了启动流上下文的方法。这使得apache得以启动并修复了这个问题。