summaryrefslogtreecommitdiff
path: root/kafka
Commit message (Expand)AuthorAgeFilesLines
* Catch socket.errors when sending / recving bytes on wake socketpairwake_socketpair_exceptionsDana Powers2017-04-041-2/+4
* Fix poll() hyperlink in KafkaClientJeff Widman2017-03-291-1/+1
* Fix typo (#1054)Jeff Widman2017-03-271-1/+1
* Bump version for developmentDana Powers2017-03-141-1/+1
* Release 1.3.31.3.3Dana Powers2017-03-141-1/+1
* Derive all api classes from Request / Response base classes (#1030)Dana Powers2017-03-1411-84/+140
* LZ4 support in kafka 0.8/0.9 does not accept a ContentSize headerDana Powers2017-03-141-6/+14
* Prefer python-lz4 over lz4f if availableDana Powers2017-03-141-7/+32
* Free lz4 decompression context to avoid leakDana Powers2017-03-141-0/+1
* Avoid re-encoding for message crc check (#1027)Dana Powers2017-03-131-6/+12
* Additional docstrings for autocommit close optionDana Powers2017-03-133-3/+17
* Optionally skip auto-commit during consumer.close (#1031)Dana Powers2017-03-132-4/+5
* Return copy of consumer subscription set (#1029)Dana Powers2017-03-131-1/+1
* Fix kwarg handing in kafka.protocol.struct.Struct (#1025)Dana Powers2017-03-091-1/+6
* Short-circuit group coordinator requests when NodeNotReady (#995)Dana Powers2017-03-091-0/+23
* Avoid unknown coordinator after client poll (#1023)Dana Powers2017-03-091-7/+6
* Add optional kwarg to ready and is_ready to disable metadata-priority logic (...Dana Powers2017-03-081-7/+16
* A few Sphinx documentation updates (#1019)Jeff Widman2017-03-081-3/+3
* Fixed couple of "leaks" when gc is disabled (#979)Max Baryshnikov2017-03-074-16/+27
* Fixup :meth: sphinx documentation for use in KafkaConsumer.rst etcDana Powers2017-03-072-35/+49
* Add ClusterMetadata documentationDana Powers2017-03-072-0/+18
* For 0.8.2, only attempt connection to coordinator if least_loaded_node succeedsDana Powers2017-03-071-1/+2
* Fixup comment reference to _maybe_connectDana Powers2017-03-071-1/+1
* Disable default consumer group (#1016)Dana Powers2017-03-061-2/+2
* change default timeout of KafkaProducer.close() to threading.TIMEOUT_MAXgaosheng2017-03-061-2/+6
* Add client info logging re bootstrap; log connection attempts to balance with...Dana Powers2017-03-062-1/+4
* Small cleanup for #962Dana Powers2017-03-061-4/+9
* Added `max_bytes` option and FetchRequest_v3 usage. (#962)Taras Voinarovskyi2017-03-064-8/+71
* Minor additional logging for consumer coordinatorDana Powers2017-03-061-0/+2
* Add more debug-level connection loggingDana Powers2017-03-061-0/+7
* Do not need str(self) when formatting to %sDana Powers2017-03-061-16/+16
* CreateTopicsRequest / Response v1 (#1012)Dana Powers2017-03-041-3/+34
* Add new broker response errorsDana Powers2017-03-041-0/+65
* Small style fixes in kafka.errorsDana Powers2017-03-041-4/+5
* When closing a broker connection without error, fail in-flight-requests with ...Dana Powers2017-03-031-1/+1
* Include the node id in BrokerConnection __repr__ (#1009)Dana Powers2017-03-031-2/+2
* Mark last_attempt time during connection close to fix blackout calculation (#...Dana Powers2017-03-031-0/+1
* Catch socket errors during ssl handshake (#1007)Dana Powers2017-03-031-1/+1
* Dont refresh metadata on failed group coordinator request unless needed (#1006)Dana Powers2017-03-031-6/+4
* Drop old brokers when rebuilding broker metadata (#1005)Dana Powers2017-03-031-3/+6
* Update vendored berkerpeksag/selectors34 to ff61b82Dana Powers2017-03-031-3/+5
* Add sphinx formatting to hyperlink methods (#898)Jeff Widman2017-03-035-45/+47
* Replace %s with %r in producer debug log message (#973)Alex2017-03-031-1/+1
* Fix sasl reconnect bug: auth future must be reset on close (#1003)Dana Powers2017-03-031-0/+1
* Add send_list_offset_request for searching offset by timestamp (#1001)charsyam2017-03-023-0/+45
* Issue 985: Clear memory wait condition before raising Exception (#999)Dana Powers2017-03-021-0/+1
* Fix BrokerConnection api_version docs default (#909)Jeff Widman2017-02-284-16/+16
* Remove dead code (#967)Jeff Widman2017-02-281-32/+0
* Fail-fast on timeout constraint violations during KafkaConsumer creation (#986)Harel Ben-Attia2017-02-281-0/+13
* PEP-8: Spacing & removed unused imports (#899)Jeff Widman2017-02-0911-63/+56
View Lorry Controller Status