summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
...
* 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
| | | berkerpeksag/selectors34@6128e06
* Update to 0.10.1.1 for integration testing (#953)Dana Powers2017-01-236-4/+192
|
* Move docstring so it shows up in Sphinx/RTD (#952)Jeff Widman2017-01-211-83/+83
|
* Add support for offsetRequestV1 messages (#951)Julien Lafaye2017-01-191-3/+32
|
* Do not re-close a disconnected connectionDana Powers2017-01-191-1/+0
|
* Drop unused last_failure time from BrokerConnectionDana Powers2017-01-191-4/+1
|
* Use connection state functions where possibleDana Powers2017-01-192-3/+4
|
* Pass error to BrokerConnection.close()Dana Powers2017-01-192-20/+28
|
* Add FetchRequest/Response_v3 structs (#943)Jeff Widman2017-01-181-2/+28
|
* Add CreateTopics / DeleteTopics Structs (#944)Jeff Widman2017-01-181-2/+60
|
* Default max_poll_records to Java default of 500 (#947)Jeff Widman2017-01-181-2/+2
|
* Remove non-pip install instructions (#940)Jeff Widman2017-01-121-14/+0
|
* Spelling and grammar changes (#923)melissacrawford3962017-01-114-90/+88
|
* Update pytest fixtures to new yield syntax (#919)Jeff Widman2017-01-112-10/+6
|
* Fix typo: coorelation --> correlation (#929)Jeff Widman2017-01-111-5/+5
|
* Make SSL warning list the correct Python versions (#924)Jeff Widman2017-01-041-3/+3
|
* Bump version for developmentDana Powers2016-12-291-1/+1
|
* Rearrange a few 1.3.2 changelog entriesDana Powers2016-12-292-6/+6
|
* Patch Release 1.3.21.3.2Dana Powers2016-12-283-2/+60
|
* Update changelogDana Powers2016-12-271-1/+2
|
* Fix of exception raise in case of auto_offset_reset is set to None in ↵Alexander Sibiryakov2016-12-271-2/+2
| | | | KafkaConsumer (#860)
* Add metadata update to pattern subscribing (#915)Dmitry Lazurkin2016-12-272-2/+27
|
* Add unreleased notes to changelogDana Powers2016-12-191-0/+49
|
* Add kafka.serializer interfaces (#912)Dana Powers2016-12-195-24/+67
|
* Add docstring for max_records (#897)Jeff Widman2016-12-191-0/+3
|
* Sort partitions before calling partitioner (#905)ms7s2016-12-192-1/+8
|
* Bug fix: ret = err => ret = err.errno (#907)guojh2016-12-171-1/+1
|
* Fix fetcher bug when processing offset out of range (#911)Dana Powers2016-12-171-1/+1
|
* Fixup doc references to max_in_flight_requests_per_connectionDana Powers2016-12-173-3/+3
|
* Fix typo: passowrd --> password (#901)Jeff Widman2016-12-121-1/+1
|
* Fix possible request draining in ensure_active_group (#896)Dana Powers2016-12-022-12/+16
|
* DOC: Fix typo 'Defualt' -> 'Default'. (#895)Rolando (Max) Espinoza2016-11-303-3/+3
|
* When hostname lookup is necessary, do every connect (#812)Evan Bender2016-11-202-5/+37
| | | | | Fixes a bug where lookup was done only once for the whole life of the process -- if a broker's IP changed, client couldn't reconnect.
* Use six.string_types for topic type check in #824Dana Powers2016-11-201-2/+2
|
* Raise exception if given a bad topic name (#824)Samuel Taylor2016-11-201-0/+7
|
* Added doc for `max_poll_records` option (#881)Taras Voinarovskyi2016-11-201-1/+2
|
* setting proper topic value in case if it's empty (#867)Alexander Sibiryakov2016-11-181-11/+4
|
* Always include an error for logging when the coordinator is marked dead (#890)Dana Powers2016-11-182-9/+9
|
* Args are optional in BrokerResponseError str (#889)Dana Powers2016-11-181-3/+3
|
* :wPass timestamp into Message, not just mimic it (#875)Taras Voinarovskyi2016-11-181-2/+6
|
* Always check for request timeouts (#887)Dana Powers2016-11-182-4/+12
| | | | * Check for requests that timeout without causing a socket read/write event
* typo (#883)sharego2016-11-151-1/+1
| | | type error
* Update param in warning (#878)Dana Powers2016-11-141-2/+2
|\ | | | | In Kafka 9, advertised.host.name was renamed to advertised.listeners
| * Update param in warningJeff Widman2016-11-111-2/+2
| | | | | | In Kafka 9, advertised.host.name was renamed to advertised.listeners
* | Remove old design notes from Kafka 8 era (#876)Jeff Widman2016-11-141-32/+0
| |