Class GetPositionResult

java.lang.Object
io.fluxcapacitor.common.api.tracking.GetPositionResult
All Implemented Interfaces:
JsonType, RequestResult

public class GetPositionResult extends Object implements RequestResult
Response to a GetPosition request, containing the current tracked position for a specific consumer and MessageType.

This result provides insight into how far a consumer has progressed in processing messages. The Position includes one or more segment-index pairs that together describe the consumption state of a consumer.

Use Cases

  • Monitor consumer lag across distributed segments
  • Confirm the effects of a ResetPosition or StorePosition
  • Diagnose stuck or lagging consumers by examining last processed indexes
See Also:
  • Constructor Details

    • GetPositionResult

      public GetPositionResult()