Skip to content
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

Added support for FetchRequest protocol version 3. #905

Merged
merged 3 commits into from
Jun 30, 2017
Merged

Added support for FetchRequest protocol version 3. #905

merged 3 commits into from
Jun 30, 2017

Commits on Jun 15, 2017

  1. Added support for FetchRequest protocol version 3. 

    This commit will add the 'MaxBytes' field to FetchRequests when the Kafka version is
0.10.1 or better. On send, it will be set to MaxResponseSize. No tests, yet.
    Michael Herstine committed Jun 15, 2017
    Configuration menu
    Copy the full SHA
    4d1eceb View commit details
    Browse the repository at this point in the history

Commits on Jun 20, 2017

  1. Add support for FetchRequest API V3. 

    This commit adds support for version 3 of the FetchRequest API. The
KIP can be found here:

    https://cwiki.apache.org/confluence/display/KAFKA/KIP-74%3A+Add+Fetch+Response+Size+Limit+in+Bytes

the PR here:

    apache/kafka#1812

and the JIRA here:

    https://issues.apache.org/jira/browse/KAFKA-2063

Should document the fact that the per-partition limits take
precedence (so the returned message may be larger than the
requested limit).
    Michael Herstine committed Jun 20, 2017
    Configuration menu
    Copy the full SHA
    b69551c View commit details
    Browse the repository at this point in the history

Commits on Jun 30, 2017

  1. Changing if condition from C-style in response to PR feedback.

    Michael Herstine committed Jun 30, 2017
    Configuration menu
    Copy the full SHA
    d6b6145 View commit details
    Browse the repository at this point in the history