我已经使用 Spark Streaming 开发了 Streaming 应用程序。当我开始运行我的应用程序时,它正在为 kafka 中的每个主题创建 dstream,然后我正在启动流式上下文。现在我想为在 kafka 中添加的新主题创建 dstream停止我的流媒体上下文。
我已经使用 Spark Streaming 开发了 Streaming 应用程序。当我开始运行我的应用程序时,它正在为 kafka 中的每个主题创建 dstream,然后我正在启动流式上下文。现在我想为在 kafka 中添加的新主题创建 dstream停止我的流媒体上下文。