-
Type:
Bug
-
Status: Open
-
Priority:
Minor
-
Resolution: Unresolved
-
Affects Version/s: None
-
Component/s: Streams
-
Tags:
-
Sprint:nxplatform next
-
Story Points:2
It's working only for the first record with an offset 0,
it should be patched with:
private boolean isProcessed(OffsetTracker offsetTracker, long offset) {
long committed = offsetTracker.get();
- return committed > 0 && committed >= offset;
+ return committed > 0 && committed > offset;
}
- is required by
-
NXP-32509 Implement indexing logic using Domain Event
-
- Resolved
-
