Matthias Endler a3c85ddf91 Fix typo in docblock

2015-12-18 17:03:27 +01:00

..

consumer

Fix _mp_consume queue variable name conflict

2015-12-09 14:00:10 -08:00

partitioner

Fix translation of Java murmur2 code, fix byte encoding for Python 3.

2015-07-28 22:38:28 -07:00

producer

Handle new topic creation / LeaderNotAvailableError in initial SimpleProducer.send_messages call

2015-12-16 22:39:51 -08:00

__init__.py

Add Murmur2Partitioner to kafka __all__ imports - fix issue 471

2015-12-02 14:38:02 -08:00

client.py

Revert broken send_produce_request try/except from PR 467 (resps=None)

2015-12-05 03:59:09 -08:00

codec.py

Fix typo in docblock

2015-12-18 17:03:27 +01:00

common.py

Support consumer metadata requests

2015-07-01 22:29:56 -07:00

conn.py

Merge pull request #473 from ecanzonieri/use_unblocking_io_for_aware_requests

2015-12-02 14:21:13 -08:00

context.py

Add Sphinx API docs

2015-01-15 18:01:40 -05:00

NOTES.md

Allow KafkaClient to take in a list of brokers for bootstrapping

2013-11-14 09:26:49 -05:00

protocol.py

Merge pull request #420 from toddpalino/master

2015-12-02 15:50:05 -08:00

util.py

Raise an error if we attempt to group duplicate topic-partition payloads

2015-06-06 16:14:49 -07:00

version.py

Bump version for development of next release

2015-12-09 13:59:41 -08:00