Dana Powers 89ea42af45 Merge pull request #426 from ucarion/ucarion-kafkaconsumer-close ...

Add KafkaConsumer#close

2015-12-06 16:08:47 -08:00

..

consumer

Merge pull request #426 from ucarion/ucarion-kafkaconsumer-close

2015-12-06 16:08:47 -08:00

partitioner

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

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

producer

Log deprecation warning for timeout argument in Producer.stop()

2015-12-06 12:18:22 -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

allow to specify compression level for codecs which support this

2015-09-12 18:22:50 +02: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

Set development version until next release

2015-06-12 11:23:52 -07:00