Only emit offsets when the topic loader has finished
Closed this issue · 0 comments
lacarvalho91 commented
Currently the topic loader will emit the offsets map for every record it consumes, instead of only when it has finished loading everything.
Closed this issue · 0 comments
Currently the topic loader will emit the offsets map for every record it consumes, instead of only when it has finished loading everything.