| .. |
|
consumer
|
A few Sphinx documentation updates (#1019)
|
2017-03-08 22:52:08 -08:00 |
|
coordinator
|
Short-circuit group coordinator requests when NodeNotReady (#995)
|
2017-03-09 14:26:09 -08:00 |
|
metrics
|
Fix quota violation exception message (#809)
|
2016-08-20 17:39:26 -07:00 |
|
partitioner
|
Sort partitions before calling partitioner (#905)
|
2016-12-19 11:26:03 -08:00 |
|
producer
|
Fixup :meth: sphinx documentation for use in KafkaConsumer.rst etc
|
2017-03-07 12:25:30 -08:00 |
|
protocol
|
Derive all api classes from Request / Response base classes
|
2017-03-13 11:16:18 -07:00 |
|
serializer
|
Add kafka.serializer interfaces (#912)
|
2016-12-19 11:27:23 -08:00 |
|
vendor
|
Fixed couple of "leaks" when gc is disabled (#979)
|
2017-03-07 13:31:46 -08:00 |
|
__init__.py
|
Add kafka.serializer interfaces (#912)
|
2016-12-19 11:27:23 -08:00 |
|
client.py
|
Derive all api classes from Request / Response base classes
|
2017-03-13 11:16:18 -07:00 |
|
client_async.py
|
Derive all api classes from Request / Response base classes
|
2017-03-13 11:16:18 -07:00 |
|
cluster.py
|
Add ClusterMetadata documentation
|
2017-03-07 12:24:55 -08: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
|
Derive all api classes from Request / Response base classes
|
2017-03-13 11:16:18 -07:00 |
|
context.py
|
Always absolute_import
|
2016-08-02 21:36:00 -07:00 |
|
errors.py
|
Add new broker response errors
|
2017-03-04 10:52:44 -08:00 |
|
future.py
|
Always absolute_import
|
2016-08-02 21:36:00 -07:00 |
|
structs.py
|
Add send_list_offset_request for searching offset by timestamp (#1001)
|
2017-03-02 14:15:01 -08:00 |
|
util.py
|
Remove dead code (#967)
|
2017-02-28 10:18:02 -08:00 |
|
version.py
|
Bump version for development
|
2016-12-29 09:18:31 -08:00 |
894cfec656