我的 Flink 作业(从一开始就(听两个 Kafka 主题：TopicA 和 TopicB。当消息从主题 A 到达时，作业将进行计算。当来自 Topic B 的消息到达时，我希望作业重置计算并重新读取 TopicA(也从头开始(。
可能吗？我没有找到重新阅读卡夫卡主题的解决方案。我有一个临时解决方案：借助 shell 脚本重新启动作业，以便重新读取 TopicA(从头开始(。
感谢您的帮助。
根据某些事件重新阅读整个 Kafka 主题。只有在启动 Flink 作业时，您才能告诉连接器从头开始读取。
javascript python java c# php android html jquery c++ css ios sql mysql arrays asp.net json python-3.x ruby-on-rails .net sql-server django objective-c excel regex ruby linux ajax iphone xml vba spring asp.net-mvc database wordpress string postgresql wpf windows xcode bash git oracle list vb.net multithreading eclipse algorithm macos powershell visual-studio image forms numpy scala function api selenium