Improvments to handling 'offsetOutOfRange' errors. (!14) · Merge requests · Itential Open Source / adapters / Notification Messaging / adapter-kafka

Bogdan Tabor requested to merge patch/ADAPT-2311 into master Aug 04, 2022

CHANGES

fetchEarliestOffsets() & fetchLatestOffsets() called sequentially, one after the other. Before, due to asynch handling of callbacks it was not guaranteed.
update locally stored offset for given (topic/partition) after offset is set for kafka consumer in 'offsetOutOfRange' handler
improved logging for offset handling

Edited Aug 04, 2022 by Bogdan Tabor

Improvments to handling 'offsetOutOfRange' errors.