FlinkでイベントのレセプションでKafkaトピックを再読み込みするには？

Question

My Flinkの仕事は、最初から2つのカフカの話題（TopicAとTopicB）を聞きます。メッセージがTopicAから届くと、ジョブは計算を行います。メッセージがTopicBから届くと、私は仕事を計算をリセットして、TopicAを最初から再読み込みしたい。

可能ですか？私はカフカの話題を再読み解する解決策を見いだせなかった。一時的な解決策があります：シェルスクリプトのおかげで仕事を再開し、TopicAを（最初から）再読み込みします。

ありがとうございました。

Answer 1

特定のイベントに基づいてカフカのトピック全体を再読み込みすることはできません。 Flinkジョブを開始するときにのみ、最初から読み取るようにコネクタに指示できます。