-
Notifications
You must be signed in to change notification settings - Fork 1.4k
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.
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
KAFKA-3977: defer fetch response parsing and raise exceptions to user #1245
Conversation
test/test_fetcher.py
Outdated
|
||
|
||
def test__unpack_message_set(): | ||
pass |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Is this still WIP?
@tvoinarovskyi does this PR conflict with your work? do you want me to wait until your changes are ready to land or are you ok rebasing + dealing with any conflicts this may cause? |
@dpkp no, rather I would like to merge this first. I did not find time to implement deferred parsing myself) |
def has_more(self): | ||
return self.messages and self.message_idx < len(self.messages) | ||
|
||
class FetchResponseMetricAggregator(object): |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Will this aggregator behave properly in case CompletedFetch is not parsed? Say we parse 2 of 3 partitions and the user uses seek()
which will cause the CompletedFetch to be discarded.
@dpkp I will merge this now. If you feel like some changes are needed please address them as a separate PR. I would like to rebase my PR on top to make it ready for merge, I think it's ready for it. |
See #1141