Problem
Two cluster delivery models coexist. EventMeshApplication.enableCluster() uses the sticky local-delivery model and intentionally does not enable partition ownership or cross-instance forwarding, yet the repository still retains PartitionOwnership, ClusterCoordinator, and HttpForwarder — a second partition-ownership / forwarding model. The partition-ownership code itself acknowledges missing generation fencing and incomplete remote offsets.
Risks
- Documentation, code, and actual deployment behavior can diverge.
- The sticky model can cause duplicate reads and amplification at the underlying MQ across instances.
- The partition-ownership model lacks the fencing needed for safe handoff.
Proposed direction
Abstract the cluster mode into a configurable DeliveryTopology:
LOCAL_STICKY_PULL current default: session pinned to an instance, local pull + local delivery
PARTITION_OWNED_PULL high-throughput: single partition owner, requires fencing and handoff
FORWARDED_DISPATCH compatibility: centralized pull + cross-instance forwarding
Each mode must document:
- duplicate-delivery semantics;
- cost / throughput characteristics;
- failure-recovery strategy;
- a corresponding E2E test.
Acceptance criteria
Related: #5293 (unify cluster delivery topology and fence stale partition owners).
Part of the Architecture Review.
Problem
Two cluster delivery models coexist.
EventMeshApplication.enableCluster()uses the sticky local-delivery model and intentionally does not enable partition ownership or cross-instance forwarding, yet the repository still retainsPartitionOwnership,ClusterCoordinator, andHttpForwarder— a second partition-ownership / forwarding model. The partition-ownership code itself acknowledges missing generation fencing and incomplete remote offsets.Risks
Proposed direction
Abstract the cluster mode into a configurable
DeliveryTopology:Each mode must document:
Acceptance criteria
DeliveryTopologyconfig selects the mode; inactive topology components are not half-wired.Related: #5293 (unify cluster delivery topology and fence stale partition owners).
Part of the Architecture Review.