Package io.fluxcapacitor.common.api.tracking

Class GetPosition

java.lang.Object

io.fluxcapacitor.common.api.Request

io.fluxcapacitor.common.api.tracking.GetPosition

All Implemented Interfaces:

JsonType

public class GetPosition
extends Request

Query to retrieve the current tracked Position for a given consumer and MessageType.

This is typically used for administrative, diagnostic, or monitoring purposes to inspect the progress of a consumer within a message stream.

Use Cases

• Determine how far a consumer has progressed in processing a given message type
• Verify if a reset or store operation has taken effect
• Generate metrics or dashboards on consumer lag

Note that this request will return the position as tracked by the Flux platform, regardless of any in-memory state held by local trackers.

See Also:

• Position
• StorePosition
• ResetPosition

Constructor Summary

Constructors

Constructor	Description
GetPosition()

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.fluxcapacitor.common.api.JsonType

toMetric

Constructor Details

GetPosition

public GetPosition()