{"status":"ok","message-type":"work","message-version":"1.0.0","message":{"indexed":{"date-parts":[[2026,4,23]],"date-time":"2026-04-23T21:04:22Z","timestamp":1776978262056,"version":"3.51.4"},"reference-count":32,"publisher":"Institute of Electrical and Electronics Engineers (IEEE)","license":[{"start":{"date-parts":[[2026,1,1]],"date-time":"2026-01-01T00:00:00Z","timestamp":1767225600000},"content-version":"vor","delay-in-days":0,"URL":"https:\/\/creativecommons.org\/licenses\/by\/4.0\/legalcode"}],"funder":[{"name":"Project ANGELA financed by Spanish National Research Agency (AEI) and Spanish Ministry of Science, Innovation and Universities","award":["PID2023-150938OB-I00"],"award-info":[{"award-number":["PID2023-150938OB-I00"]}]}],"content-domain":{"domain":[],"crossmark-restriction":false},"short-container-title":["IEEE Access"],"published-print":{"date-parts":[[2026]]},"DOI":"10.1109\/access.2026.3683986","type":"journal-article","created":{"date-parts":[[2026,4,22]],"date-time":"2026-04-22T19:50:56Z","timestamp":1776887456000},"page":"59801-59814","source":"Crossref","is-referenced-by-count":0,"title":["A Selective Reprocessing Mechanism to Achieve End-to-End Data Consistency in Streaming Systems"],"prefix":"10.1109","volume":"14","author":[{"ORCID":"https:\/\/orcid.org\/0000-0002-0128-0783","authenticated-orcid":false,"given":"Felipe","family":"Cerezo","sequence":"first","affiliation":[{"name":"Department of Informatics and Statistics, University Rey Juan Carlos, Móstoles, Spain"}],"role":[{"role":"author","vocabulary":"crossref"}]},{"ORCID":"https:\/\/orcid.org\/0000-0003-0286-4219","authenticated-orcid":false,"given":"Carlos E.","family":"Cuesta","sequence":"additional","affiliation":[{"name":"Department of Informatics and Statistics, University Rey Juan Carlos, Móstoles, Spain"}],"role":[{"role":"author","vocabulary":"crossref"}]},{"ORCID":"https:\/\/orcid.org\/0000-0003-0604-7312","authenticated-orcid":false,"given":"Belen","family":"Vela","sequence":"additional","affiliation":[{"name":"Department of Informatics and Statistics, University Rey Juan Carlos, Móstoles, Spain"}],"role":[{"role":"author","vocabulary":"crossref"}]}],"member":"263","reference":[{"key":"ref1","doi-asserted-by":"publisher","DOI":"10.1109\/MC.2012.33"},{"key":"ref2","volume-title":"Streaming Systems: The What, Where, When, and How of Large-Scale Data Processing","author":"Akidau","year":"2018"},{"key":"ref3","doi-asserted-by":"publisher","DOI":"10.1145\/2460276.2462076"},{"key":"ref4","doi-asserted-by":"publisher","DOI":"10.1109\/MC.2012.37"},{"key":"ref5","doi-asserted-by":"publisher","DOI":"10.14778\/3137765.3137777"},{"key":"ref6","volume-title":"Cassandra: The Definitive Guide: Distributed Data at Web Scale","author":"Carpenter","year":"2022"},{"key":"ref7","doi-asserted-by":"publisher","DOI":"10.1145\/214451.214456"},{"key":"ref8","doi-asserted-by":"publisher","DOI":"10.1109\/ICSA-C.2019.00042"},{"key":"ref9","volume-title":"Spark","author":"Ganelin","year":"2016"},{"key":"ref10","doi-asserted-by":"publisher","DOI":"10.1145\/564585.564601"},{"key":"ref11","volume-title":"Elasticsearch: The Definitive Guide","author":"Gormley","year":"2015"},{"key":"ref12","doi-asserted-by":"publisher","DOI":"10.1145\/78969.78972"},{"key":"ref13","volume-title":"Apache Flume: Distributed Log Collection for Hadoop: Stream Data to Hadoop Using Apache Flume","author":"Hoffman","year":"2013"},{"key":"ref14","volume-title":"Stream Processing With Apache Flink","author":"Hueske","year":"2019"},{"key":"ref15","doi-asserted-by":"publisher","DOI":"10.1109\/ICDE.2005.72"},{"key":"ref16","volume-title":"Designing Data-Intensive Applications: The Big Ideas Behind Reliable, Scalable, and Maintainable Systems","author":"Kleppmann","year":"2017"},{"key":"ref17","doi-asserted-by":"publisher","DOI":"10.1109\/TPDS.2017.2697382"},{"key":"ref18","first-page":"18","article-title":"Questioning the Lambda architecture","volume":"205","author":"Kreps","year":"2014","journal-title":"Online Article"},{"key":"ref19","volume-title":"I Heart Logs: Event Data, Stream Processing, and Data Integration","author":"Kreps","year":"2014"},{"key":"ref20","volume-title":"Big Data: Principles and Best Practices of Scalable Realtime Data Systems","author":"Marz","year":"2015"},{"key":"ref21","volume-title":"Exactly-Once Semantics is Possible: Here\u2019s How Apache Kafka Does it","author":"Narkhede","year":"2017"},{"key":"ref22","volume-title":"Kafka: The Definitive Guide: Real-Time Data and Stream Processing at Scale","author":"Narkhede","year":"2017"},{"key":"ref23","doi-asserted-by":"publisher","DOI":"10.14778\/3137765.3137770"},{"key":"ref24","volume-title":"Release It! Design and Deploy Production-Ready Software, Book Version: P5.1, The Pragmatic Bookshelf","author":"Nygard","year":"2012"},{"key":"ref25","doi-asserted-by":"publisher","DOI":"10.1007\/978-1-4842-5955-9"},{"key":"ref26","volume-title":"Reprocessing Previously Processed Data","year":"2023"},{"key":"ref27","doi-asserted-by":"publisher","DOI":"10.1145\/1435417.1435432"},{"key":"ref28","volume-title":"Enabling Exactly-Once in Kafka Streams","author":"Wang","year":"2017"},{"key":"ref29","doi-asserted-by":"publisher","DOI":"10.1007\/s11704-020-0248-x"},{"key":"ref30","volume-title":"An Architecture for fast and general data processing on large clusters","author":"Zaharia","year":"2017"},{"key":"ref31","volume-title":"Kibana: Visualize, explore, manage data Elasticsearch","year":"2025"},{"key":"ref32","volume-title":"Database of Databases-Elasticsearch, Database of Databases","year":"2022"}],"container-title":["IEEE Access"],"original-title":[],"link":[{"URL":"http:\/\/xplorestaging.ieee.org\/ielx8\/6287639\/11323511\/11481073.pdf?arnumber=11481073","content-type":"unspecified","content-version":"vor","intended-application":"similarity-checking"}],"deposited":{"date-parts":[[2026,4,23]],"date-time":"2026-04-23T20:00:08Z","timestamp":1776974408000},"score":1,"resource":{"primary":{"URL":"https:\/\/ieeexplore.ieee.org\/document\/11481073\/"}},"subtitle":[],"short-title":[],"issued":{"date-parts":[[2026]]},"references-count":32,"URL":"https:\/\/doi.org\/10.1109\/access.2026.3683986","relation":{},"ISSN":["2169-3536"],"issn-type":[{"value":"2169-3536","type":"electronic"}],"subject":[],"published":{"date-parts":[[2026]]}}}