是否有可能动态更新spark-kafka消费者中的主题列表？
我有一个使用spark-kafka消费者的Spark Streaming应用程序.说最初我有spark-kakfa消费者在听主题:["test"],过了一会儿我的主题列表更新为["test","testNew"].现在有办法更新spark-kafka消费者主题列表,并要求spark-kafka消费者使用数据来获取更新的主题列表,而无需停止sparkStreaming应用程序或sparkStreaming上下文
apache-kafka apache-spark spark-streaming
apache-kafka ×1
apache-spark ×1
spark-streaming ×1