Code

MultiProcess consumer#35

Code

Merged

mumrah merged 20 commits intodpkp:masterdpkp/kafka-python:masterfrom

mahendra:partitionmahendra/kafka-python:partitionCopy head branch name to clipboard

Jul 26, 2013

Commits

Commits on Jun 12, 2013

• Add support to consume messages from specific partitions

  Show description for ab72da3
  mahendra

  committed
  ab72da3

  Copy full SHA for ab72da3

Commits on Jun 20, 2013

• Merge branch 'master' into partition

  mahendra

  committed
  aec3884

  Copy full SHA for aec3884

Commits on Jun 24, 2013

• Add support for multi-process consumer

  mahendra

  committed
  b578725

  Copy full SHA for b578725

• Minor bug fix

  mahendra

  committed
  e85190e

  Copy full SHA for e85190e

Commits on Jun 25, 2013

• Added more documentation and clean up duplicate code

  mahendra

  committed
  c7dfeba

  Copy full SHA for c7dfeba

• Added the modules in __init__.py

  mahendra

  committed
  2e38a52

  Copy full SHA for 2e38a52

• Implement blocking get_messages for SimpleConsumer

  Show description for b022be2
  mahendra

  committed
  b022be2

  Copy full SHA for b022be2

• Added some comments about message state

  mahendra

  committed
  99da57f

  Copy full SHA for 99da57f

• Got MultiProcessConsumer working

  Show description for 65c8eb1
  mahendra

  committed
  65c8eb1

  Copy full SHA for 65c8eb1

• Merge branch 'master' into partition

  Show description for 2ce3217
  mahendra

  committed
  2ce3217

  Copy full SHA for 2ce3217

Commits on Jun 27, 2013

• Fix a bug in seek.

  Show description for d6d7299
  mahendra

  committed
  d6d7299

  Copy full SHA for d6d7299

• Re-init the sockets in the new process

  mahendra

  committed
  b3fece5

  Copy full SHA for b3fece5

• Test cases for multi-process consumer and blocking APIs

  mahendra

  committed
  36b5f81

  Copy full SHA for 36b5f81

• Add TODO comments

  mahendra

  committed
  c2a49c1

  Copy full SHA for c2a49c1

Commits on Jun 28, 2013

• Fix markup in README

  mahendra

  committed
  6b76d9d

  Copy full SHA for 6b76d9d

• Fix markups

  mahendra

  committed
  9a557ed

  Copy full SHA for 9a557ed

• Minor markup fix

  mahendra

  committed
  7b2a08f

  Copy full SHA for 7b2a08f

• Fix cases of single partition

  mahendra

  committed
  c13ee1d

  Copy full SHA for c13ee1d

• Add more cleanup in consumer.stop()

  mahendra

  committed
  c54a2ed

  Copy full SHA for c54a2ed

Commits on Jul 1, 2013

• Fix minor bug in offset management

  Show description for 1d278f0
  mahendra

  committed
  1d278f0

  Copy full SHA for 1d278f0