Skip to content
Permalink

Comparing changes

Choose two branches to see what’s changed or to start a new pull request. If you need to, you can also or learn more about diff comparisons.

Open a pull request

Create a new pull request by comparing changes across two branches. If you need to, you can also . Learn more about diff comparisons here.
base repository: mahendra/kafka-python
Failed to load repositories. Confirm that selected base ref is valid, then try again.
Loading
base: gevent
Choose a base ref
...
head repository: mahendra/kafka-python
Failed to load repositories. Confirm that selected head ref is valid, then try again.
Loading
compare: zookeeper
Choose a head ref
Checking mergeability… Don’t worry, you can still create the pull request.
  • 12 commits
  • 9 files changed
  • 1 contributor

Commits on Jul 2, 2013

  1. Configuration menu
    Copy the full SHA
    4a875b6 View commit details
    Browse the repository at this point in the history
  2. Update setup.py

    mahendra committed Jul 2, 2013
    Configuration menu
    Copy the full SHA
    ac9bad8 View commit details
    Browse the repository at this point in the history

Commits on Jul 3, 2013

  1. Improvements in Zookeeper Consumer

    * Correct behaviour during consumer rebalancing
    * Correct behaviour for minor APIs like close(), pending(), seek() etc.
    * Improved documentation
    mahendra committed Jul 3, 2013
    Configuration menu
    Copy the full SHA
    3b5c52c View commit details
    Browse the repository at this point in the history
  2. Remove retry in zookeeper producer

    This can be made common for all producers later
    mahendra committed Jul 3, 2013
    Configuration menu
    Copy the full SHA
    172d838 View commit details
    Browse the repository at this point in the history
  3. Configuration menu
    Copy the full SHA
    b2f232e View commit details
    Browse the repository at this point in the history
  4. Moved logic from queues to locked shared memory

    The queues approach had a problem. Say the consumer is not
    used to fetch messages for a while. In this while the allocation
    has changed multiple times. When the next invocation of the consumer
    happens, the oldest message is fetched from the queue. It will take
    a while before the consumer catches up
    
    The approach has been simplified with a shared memory protected by a
    lock and notified using an event
    mahendra committed Jul 3, 2013
    Configuration menu
    Copy the full SHA
    b5b7f39 View commit details
    Browse the repository at this point in the history
  5. Minor bug fixes

    Ensure that the standby consumer logic works
    Also add a __repr__ method for Zookeeper consumer
    mahendra committed Jul 3, 2013
    Configuration menu
    Copy the full SHA
    010f432 View commit details
    Browse the repository at this point in the history

Commits on Jul 4, 2013

  1. Configuration menu
    Copy the full SHA
    04a200a View commit details
    Browse the repository at this point in the history
  2. Configuration menu
    Copy the full SHA
    179b5d0 View commit details
    Browse the repository at this point in the history

Commits on Jul 8, 2013

  1. Test cases for zookeeper based consumers

    Other changes
    * If zookeeper consumer was run from the same process, kazoo Partitioner
      identifier would have been the same - resulting in errors. Fixed
    * Add support for chroot to a Zookeeper path
    * Remove dependency on simplejson
    * Reduce the sleep time for the partitioner (in acquired state)
    mahendra committed Jul 8, 2013
    Configuration menu
    Copy the full SHA
    94b9e1c View commit details
    Browse the repository at this point in the history

Commits on Aug 13, 2013

  1. Configuration menu
    Copy the full SHA
    f311cf4 View commit details
    Browse the repository at this point in the history

Commits on Sep 26, 2013

  1. Merge branch 'gevent' into zookeeper

    Conflicts:
    	kafka/client.py
    	kafka/conn.py
    	test/test_integration.py
    mahendra committed Sep 26, 2013
    Configuration menu
    Copy the full SHA
    84fef2b View commit details
    Browse the repository at this point in the history
Loading