だから私はHeadを取り、それから処理を開始します。これをスケーリングし、ポッド/インスタンスごとに8スレッドのエグゼキュータサービスを使用する場合、システムが突然シャットダウンすると、「メッセージ」はすでに取得/消費されていると見なされることになります。
代わりにRStreamオブジェクトを使用する必要があります。これにより、コンシューマーごとに未消費の要素を追跡できます。
だから私はHeadを取り、それから処理を開始します。これをスケーリングし、ポッド/インスタンスごとに8スレッドのエグゼキュータサービスを使用する場合、システムが突然シャットダウンすると、「メッセージ」はすでに取得/消費されていると見なされることになります。
代わりにRStreamオブジェクトを使用する必要があります。これにより、コンシューマーごとに未消費の要素を追跡できます。