Dana Powers 1f6be11b09 Merge pull request #507 from dpkp/deprecation_warnings ...

Add DeprecationWarnings to legacy classes

2016-01-12 22:57:24 -08:00

..

consumer

Merge pull request #507 from dpkp/deprecation_warnings

2016-01-12 22:57:24 -08:00

coordinator

KAFKA-2978: consumer stops fetching when consumed and fetch positions get out of sync

2016-01-10 12:06:04 -08:00

partitioner

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

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

producer

Merge branch '0.9'

2016-01-07 18:51:14 -08:00

protocol

Message value can be None

2016-01-03 18:46:09 -08:00

__init__.py

Add DeprecationWarnings to legacy KafkaClient, Simple/MultiProcess/Consumer, and KafkaConnection

2016-01-12 16:52:30 -08:00

client_async.py

Remove sleep call in client.poll -- expect callers to manage this and log warning

2016-01-12 14:43:49 -08:00

client.py

Add DeprecationWarnings to legacy KafkaClient, Simple/MultiProcess/Consumer, and KafkaConnection

2016-01-12 16:52:30 -08:00

cluster.py

Improve cluster.ttl() readability

2016-01-10 15:43:33 -08:00

codec.py

Docstring updates

2016-01-07 17:03:08 -08:00

common.py

Use ConnectionError rather than new DisconnectError

2015-12-29 17:48:10 -08:00

conn.py

Add DeprecationWarnings to legacy KafkaClient, Simple/MultiProcess/Consumer, and KafkaConnection

2016-01-12 16:52:30 -08:00

context.py

Convert OffsetCommit and OffsetFetch protocol encode/decode

2015-12-10 11:25:15 -08:00

future.py

Call errbacks with future.exception

2016-01-03 23:31:09 -08:00

NOTES.md

Allow KafkaClient to take in a list of brokers for bootstrapping

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

util.py

Drop kafka_bytestring

2015-12-10 18:37:03 -08:00

version.py

Merge branch '0.9'

2016-01-07 18:51:14 -08:00