public abstract static class TimestampPolicy.PartitionContext
extends java.lang.Object
TimestampPolicy
.Constructor and Description |
---|
PartitionContext() |
Modifier and Type | Method and Description |
---|---|
abstract Instant |
getBacklogCheckTime()
The time at which latest offset for the partition was fetched in order to calculate backlog.
|
abstract long |
getMessageBacklog()
Current backlog in messages (latest offset of the partition - last processed record offset).
|
public abstract long getMessageBacklog()
public abstract Instant getBacklogCheckTime()
TimestampPolicyFactory.LogAppendTimePolicy
.