flink 作业是否可以在运行时根据来自控件主题或文件的某些控件从不同的主题读取

Question

Flink 作业是否可以在运行时根据来自控件主题或文件的某些控件从不同的主题读取

Answer 1

没有什么能阻止你从文件或控件主题中读取字符串，并将该字符串作为主题名称传递给 FlinkKafkaConsumer 构造函数。

但是，如果您的目标是在作业运行一段时间后开始阅读其他主题，我认为这是不可能的。但是，您可以做的是使用主题发现来让您的作业动态发现新主题并开始从中使用它们。