Details
-
Improvement
-
Resolution: Fixed
-
Major
-
Goldfish GA
Description
Working on achieving exactly-once semantics for the Kafka ingestion, will involve discarding the insertion of already-present records based on the stored offset. This will involve allowing the records only if the
(stored offset) < (offset present in the record)
|
This will also help in the consistency of the query results.
Attachments
For Gerrit Dashboard: MB-61551 | ||||||
---|---|---|---|---|---|---|
# | Subject | Branch | Project | Status | CR | V |
208751,5 | MB-61551: Filter records in kafka ingestion pipeline | master | cbas-core | Status: MERGED | +2 | +1 |