Subscription: detect outdated subscription event for better consumer exception control

[VGalaxies]

As title.

[Copilot]

Copilot reviewed 8 out of 8 changed files in this pull request and generated no comments.

Comments suppressed due to low confidence (2)

iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/base/AbstractSubscriptionConsumer.java:1022

• [nitpick] Verify that comparing the payload with ErrorPayload.OUTDATED_ERROR_PAYLOAD using Objects.equals relies on reference equality as intended. If a different instance is ever used for outdated errors, this check may fail.

if (Objects.equals(payload, ErrorPayload.OUTDATED_ERROR_PAYLOAD)) {

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/SubscriptionPrefetchingQueue.java:602

• [nitpick] Ensure that the assumption of commit IDs being monotonically increasing, as used in the outdated check, is documented and covered with unit tests to prevent potential misinterpretations in the future.

return PipeDataNodeAgent.runtime().getRebootTimes() > commitContext.getRebootTimes() || initialCommitId > commitContext.getCommitId();