For instance, CSV reader should expose file name, current file offset, current record number, and a "more to come" flag, with which further readers could promptly flush their groups (thus the performance flag).
Kafka reader could similarly expose topic name and topic offset as well as message headers.
For instance, CSV reader should expose file name, current file offset, current record number, and a "more to come" flag, with which further readers could promptly flush their groups (thus the performance flag). Kafka reader could similarly expose topic name and topic offset as well as message headers.