New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Terminate if current offset is greater than log end offset #11

Open

lacarvalho91 opened this issue Nov 4, 2018 · 0 comments

Contributor

lacarvalho91 commented Nov 4, 2018

We have seen a scenario where Kafka is in such a weird state that a consumer can have negative lag e.g:

TOPIC           PARTITION    CURRENT-OFFSET  LOG-END-OFFSET  LAG
map.title.gb    8            199053          2919            -196134
map.offer.es    7            57801           0428            -47373
map.season.es   6            699             113             -586
map.series.gb   6            13330           58              -13272

We should try and detect this at the start and fail with an error if this happens

The text was updated successfully, but these errors were encountered:

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment