いくつかの条件に基づいて行をフィルタリングし、MongoDB にロードするだけの Kafka Streaming アプリを作成しました。
ストリーミング プロセスは問題なく動作していますが、コードに問題があるため、データ全体を再処理したいと考えています。
1 つの方法は、ストリーミング アプリを強制終了し、コンシューマー グループ ID を変更し、mongo からデータを削除して、アプリを再実行することです。
コンシューマ グループ ID を変更せずにこのシナリオを実現する方法。
<< Kafka 0.10 バージョンを使用しています >>
どうもありがとうパリ