summaryrefslogtreecommitdiff
Commit message (Expand)AuthorAgeFilesLines
* Release 1.3.41.3.4Dana Powers2017-08-132-1/+59
* Add 0.11.0.0 to travis test matrix, remove 0.10.1.1; use scala 2.11 artifacts...Dana Powers2017-08-132-30/+18
* Initialize metadata_snapshot in group coordinator (#1174)Dana Powers2017-08-131-6/+9
* Select on sockets to avoid busy polling during bootstrap (#1175)Dana Powers2017-08-131-0/+2
* Merge pull request #1161 from dpkp/issue1036_offset_by_timeTaras Voinarovskyi2017-08-077-68/+609
|\
| * Added unit tests for fetcher's `_reset_offset` and related functions.Taras Voinarovskiy2017-08-073-7/+199
| * Added `beginning_offsets` and `end_offsets` API's and fixed @jeffwidman revie...Taras Voinarovskiy2017-08-074-17/+142
| * Fix test for older brokersTaras Voinarovskiy2017-08-071-1/+1
| * Changed retrieve_offsets to allow fetching multiple offsets at onceTaras Voinarovskiy2017-08-073-100/+174
| * Fix test for older brokersTaras Voinarovskiy2017-08-071-2/+4
| * Added basic support for offsets_for_times API. Still needs to group by nodes ...Taras Voinarovskiy2017-08-076-21/+169
|/
* Add private map of api key -> min/max versions to BrokerConnection (#1169)Dana Powers2017-08-062-11/+58
* Fixed Issue 1033.Raise AssertionError when decompression unsupported. (#1159)webber2017-08-051-0/+7
* conn: Catch ssl.EOFErrors on Python3.3 so we close the failing conn (#1162)Hannu Valtonen2017-08-011-1/+3
* Merge pull request #1160 from dpkp/issue1155Taras Voinarovskyi2017-07-311-0/+1
|\
| * Make UnknownTopicOrPartitionError retriable errorissue1155Taras Voinarovskiy2017-07-301-0/+1
|/
* Fix batch expiry messages to state secondsDominic Evans2017-07-261-3/+3
* Use for join-time-max and sync-time-max metrics Max() measure function (#1146)Alexey Pervushin2017-07-201-2/+2
* added gssapi support (Kerberos) for SASL (#1152)Harald2017-07-201-2/+75
* Add note, that `max_in_flight_requests_per_connection>1` may change order or ...Taras Voinarovskyi2017-07-171-1/+4
* producer: fix produce timeout message (#1151)Mika Eloranta2017-07-171-1/+1
* Protocol updates for 0.11.0.0 (#1127)Dana Powers2017-07-097-41/+508
* Use logging's built-in string interpolationJeff Widman2017-07-072-6/+5
* change_subscription called only when necessary (#1132)Petr Ĺ ebek2017-07-071-2/+3
* Fix typoJeff Widman2017-07-011-1/+1
* producer: Set exit timeout to 0 for atexit handler to match __del__ (#1126)Hannu Valtonen2017-06-191-1/+1
* KIP-144: Exponential backoff for broker reconnections (#1124)Dana Powers2017-06-194-22/+69
* Backoff on unavailable group coordinator retry (#1125)Dana Powers2017-06-191-0/+2
* Fixup for #1085 -- only check for changed metadata on disconnected nodesDana Powers2017-06-181-17/+23
* Deal with brokers that disappear, reappear with different IP address (#1085)Mike Fischer2017-06-181-1/+12
* Do not test fetched_size with fetch_max_bytes since 0.11 brokers will return ...Dana Powers2017-06-181-3/+0
* Increase max_buffer_size for test_large_messagesDana Powers2017-06-181-2/+8
* Fix fetch_max_bytes=1 consumer integration testDana Powers2017-06-181-10/+10
* Use fixture hostname (dont assume localhost)Dana Powers2017-06-182-2/+2
* Add 0.11.0.0 server resources (reduced offsets.topic.replication.factor=1)Dana Powers2017-06-183-0/+188
* Describe consumer thread-safetyLinus Wallgren2017-06-164-3/+25
* Update exception docstringAndrew Kowalik2017-06-161-1/+1
* raise KafkaTimeoutException when flush times outAndrew Kowalik2017-06-162-2/+9
* Follow-up: support manual py26 testing; dont advertise 3.3 supportDana Powers2017-06-162-3/+10
* Add kafka 0.10.2.1 into integration testing version (#1096)Jianbin Wei2017-06-169-20/+199
* pylint 1.7.0+ supports python 3.6 and merge py36 into common tstenv (#1095)Jianbin Wei2017-05-031-6/+1
* Improve error message when expiring batches in KafkaProducer (#1077)Dana Powers2017-05-031-7/+11
* Warn dont raise on DNS lookup failures (#1091)Dana Powers2017-05-031-5/+7
* Ignore not-context-manager pylint error (#1092)Dana Powers2017-04-291-0/+3
* Follow-up to #1068: remove not-implemented commentsDana Powers2017-04-102-2/+2
* readthedocs.io follow-up to #1074 for docs/Dana Powers2017-04-103-3/+3
* Update RTD links with https / .io (#1074)Jeff Widman2017-04-101-6/+6
* Timeout idle connections via connections_max_idle_ms (#1068)Dana Powers2017-04-104-6/+135
* Avoid multiple connection attempts when refreshing metadata (#1067)Dana Powers2017-04-052-58/+73
* Catch socket.errors when sending / recving bytes on wake socketpair (#1069)Dana Powers2017-04-051-2/+4