ローカル クラスターを使用して Trident トポロジを再実行すると、次のエラーが発生します。
Current batch (1) is behind state's batch
前のトランザクション ID はカウンター値と共に Cassandra に保存されますが、最初はトランザクション ID が常に 1 に設定されているように見えるため、単純な検証ステップ (現在のトランザクション ID が前のトランザクション ID より大きい) は常に失敗します。
Trident に現在のバッチ ID を保持させる方法は?
ありがとう！