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

MultiProcessConsumer: an option to use current offsets #354

Closed
wants to merge 5 commits into from
Closed

MultiProcessConsumer: an option to use current offsets #354

wants to merge 5 commits into from

Commits on Mar 26, 2015

  1. added parameter for child consumers to load their offsets on init

    @mahall @vshlapakov
    mahall authored and vshlapakov committed Mar 26, 2015
    Configuration menu
    Copy the full SHA
    c04916f View commit details
    Browse the repository at this point in the history

  2. forgot to add load_initial_offsets to SimpleConsumer as well as Consumer 

    Conflicts fixed:
	kafka/consumer/simple.py
    @mahall @vshlapakov
    mahall authored and vshlapakov committed Mar 26, 2015
    Configuration menu
    Copy the full SHA
    2010cf9 View commit details
    Browse the repository at this point in the history

  3. Fixed base init method for MPConsumer

    @vshlapakov
    vshlapakov committed Mar 26, 2015
    Configuration menu
    Copy the full SHA
    558e753 View commit details
    Browse the repository at this point in the history

  4. Added basic tests for load_initial_offsets option

    @vshlapakov
    vshlapakov committed Mar 26, 2015
    Configuration menu
    Copy the full SHA
    a894869 View commit details
    Browse the repository at this point in the history

  5. Skip these tests: no OffsetCommitRequest for 0.8.0

    @vshlapakov
    vshlapakov committed Mar 26, 2015
    Configuration menu
    Copy the full SHA
    31a2668 View commit details
    Browse the repository at this point in the history