summaryrefslogtreecommitdiff
path: root/kafka
Commit message (Expand)AuthorAgeFilesLines
* Avoid re-encoding for message crc checkfaster_validate_crcDana Powers2017-03-131-6/+12
* 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
* Add MetadataRequest_v2 and MetadataResponse_v2 structures for KIP-78 (#974)Taras Voinarovskyi2017-02-091-2/+34
* KIP-88 / KAFKA-3853: OffsetFetch v2 structs (#971)Jeff Widman2017-02-081-2/+30
* Move BrokerConnection docstring to class (#968)Jeff Widman2017-02-081-68/+69
* DRY-up the MetadataRequest_v1 struct (#966)Jeff Widman2017-02-081-4/+5
* Add JoinGroup v1 structs (#965)Jeff Widman2017-02-081-2/+25
* DRY-up the OffsetCommitResponse Structs (#970)Jeff Widman2017-02-031-17/+5
* DRY-up the OffsetFetch structs (#964)Jeff Widman2017-02-031-17/+4
* time --> timestamp to match Java API (#969)Jeff Widman2017-02-031-1/+1
* Use select to poll sockets for read to reduce CPU usage (#958)Jianbin Wei2017-02-031-0/+10
* Fix raise exception from SubscriptionState.assign_from_subscribed (#960)Petr Šebek2017-02-031-1/+1
* Add support for Python built without ssl (#939) (#954)Sho Minagawa2017-02-031-17/+28
* use select.select without instance bounding (#949)adamwen2017-01-231-1/+1
View Lorry Controller Status