Dana Powers 92ed46eee4 Always include an error for logging when the coordinator is marked dead

2016-11-18 09:20:41 -08:00

..

consumer

Revert consumer iterators from max_poll_records (#856)

2016-10-24 11:24:16 -07:00

coordinator

Always include an error for logging when the coordinator is marked dead

2016-11-18 09:20:41 -08:00

metrics

Fix quota violation exception message (#809)

2016-08-20 17:39:26 -07:00

partitioner

Fix murmur2 bug handling python2 bytes that do not ascii encode (#815)

2016-10-22 09:48:08 -07:00

producer

Added ssl_password config option to KafkaProducer class, identical to… (#830)

2016-09-15 16:28:59 -07:00

protocol

Fix message timestamp_type (#828)

2016-09-15 16:29:19 -07:00

vendor

Vendor six 1.10.0

2016-08-01 14:47:40 -07:00

__init__.py

from kafka import ConsumerRebalanceListener, OffsetAndMetadata

2016-09-04 09:26:41 -07:00

client_async.py

Added ssl_password config option to KafkaProducer class, identical to… (#830)

2016-09-15 16:28:59 -07:00

client.py

Always absolute_import

2016-08-02 21:36:00 -07:00

cluster.py

Metadata with_partitions() (#787)

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

codec.py

Vendor six 1.10.0

2016-08-01 14:47:40 -07:00

common.py

Always absolute_import

2016-08-02 21:36:00 -07:00

conn.py

Monkeypatch max_in_flight_requests_per_connection when checking broker version (#834)

2016-09-28 09:56:11 -07:00

context.py

Always absolute_import

2016-08-02 21:36:00 -07:00

errors.py

implement sasl PLAIN mechanism

2016-08-03 11:44:33 -07:00

future.py

Always absolute_import

2016-08-02 21:36:00 -07:00

NOTES.md

Allow KafkaClient to take in a list of brokers for bootstrapping

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

structs.py

Always absolute_import

2016-08-02 21:36:00 -07:00

util.py

Always absolute_import

2016-08-02 21:36:00 -07:00

version.py

Bump version for development

2016-08-11 15:15:18 -07:00