Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | Switch to 0.10.1.10_10_1_1 | Dana Powers | 2017-01-21 | 6 | -4/+4 |
| | |||||
* | Update docs | Dana Powers | 2017-01-21 | 1 | -2/+2 |
| | |||||
* | Move 0.10 integration testing to 0.10.1.0 | Dana Powers | 2017-01-21 | 2 | -2/+2 |
| | |||||
* | Add resource files for 0.10.1.0 fixtures | Dana Powers | 2017-01-21 | 3 | -0/+188 |
| | |||||
* | Move docstring so it shows up in Sphinx/RTD (#952) | Jeff Widman | 2017-01-21 | 1 | -83/+83 |
| | |||||
* | Add support for offsetRequestV1 messages (#951) | Julien Lafaye | 2017-01-19 | 1 | -3/+32 |
| | |||||
* | Do not re-close a disconnected connection | Dana Powers | 2017-01-19 | 1 | -1/+0 |
| | |||||
* | Drop unused last_failure time from BrokerConnection | Dana Powers | 2017-01-19 | 1 | -4/+1 |
| | |||||
* | Use connection state functions where possible | Dana Powers | 2017-01-19 | 2 | -3/+4 |
| | |||||
* | Pass error to BrokerConnection.close() | Dana Powers | 2017-01-19 | 2 | -20/+28 |
| | |||||
* | Add FetchRequest/Response_v3 structs (#943) | Jeff Widman | 2017-01-18 | 1 | -2/+28 |
| | |||||
* | Add CreateTopics / DeleteTopics Structs (#944) | Jeff Widman | 2017-01-18 | 1 | -2/+60 |
| | |||||
* | Default max_poll_records to Java default of 500 (#947) | Jeff Widman | 2017-01-18 | 1 | -2/+2 |
| | |||||
* | Remove non-pip install instructions (#940) | Jeff Widman | 2017-01-12 | 1 | -14/+0 |
| | |||||
* | Spelling and grammar changes (#923) | melissacrawford396 | 2017-01-11 | 4 | -90/+88 |
| | |||||
* | Update pytest fixtures to new yield syntax (#919) | Jeff Widman | 2017-01-11 | 2 | -10/+6 |
| | |||||
* | Fix typo: coorelation --> correlation (#929) | Jeff Widman | 2017-01-11 | 1 | -5/+5 |
| | |||||
* | Make SSL warning list the correct Python versions (#924) | Jeff Widman | 2017-01-04 | 1 | -3/+3 |
| | |||||
* | Bump version for development | Dana Powers | 2016-12-29 | 1 | -1/+1 |
| | |||||
* | Rearrange a few 1.3.2 changelog entries | Dana Powers | 2016-12-29 | 2 | -6/+6 |
| | |||||
* | Patch Release 1.3.21.3.2 | Dana Powers | 2016-12-28 | 3 | -2/+60 |
| | |||||
* | Update changelog | Dana Powers | 2016-12-27 | 1 | -1/+2 |
| | |||||
* | Fix of exception raise in case of auto_offset_reset is set to None in ↵ | Alexander Sibiryakov | 2016-12-27 | 1 | -2/+2 |
| | | | | KafkaConsumer (#860) | ||||
* | Add metadata update to pattern subscribing (#915) | Dmitry Lazurkin | 2016-12-27 | 2 | -2/+27 |
| | |||||
* | Add unreleased notes to changelog | Dana Powers | 2016-12-19 | 1 | -0/+49 |
| | |||||
* | Add kafka.serializer interfaces (#912) | Dana Powers | 2016-12-19 | 5 | -24/+67 |
| | |||||
* | Add docstring for max_records (#897) | Jeff Widman | 2016-12-19 | 1 | -0/+3 |
| | |||||
* | Sort partitions before calling partitioner (#905) | ms7s | 2016-12-19 | 2 | -1/+8 |
| | |||||
* | Bug fix: ret = err => ret = err.errno (#907) | guojh | 2016-12-17 | 1 | -1/+1 |
| | |||||
* | Fix fetcher bug when processing offset out of range (#911) | Dana Powers | 2016-12-17 | 1 | -1/+1 |
| | |||||
* | Fixup doc references to max_in_flight_requests_per_connection | Dana Powers | 2016-12-17 | 3 | -3/+3 |
| | |||||
* | Fix typo: passowrd --> password (#901) | Jeff Widman | 2016-12-12 | 1 | -1/+1 |
| | |||||
* | Fix possible request draining in ensure_active_group (#896) | Dana Powers | 2016-12-02 | 2 | -12/+16 |
| | |||||
* | DOC: Fix typo 'Defualt' -> 'Default'. (#895) | Rolando (Max) Espinoza | 2016-11-30 | 3 | -3/+3 |
| | |||||
* | When hostname lookup is necessary, do every connect (#812) | Evan Bender | 2016-11-20 | 2 | -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 #824 | Dana Powers | 2016-11-20 | 1 | -2/+2 |
| | |||||
* | Raise exception if given a bad topic name (#824) | Samuel Taylor | 2016-11-20 | 1 | -0/+7 |
| | |||||
* | Added doc for `max_poll_records` option (#881) | Taras Voinarovskyi | 2016-11-20 | 1 | -1/+2 |
| | |||||
* | setting proper topic value in case if it's empty (#867) | Alexander Sibiryakov | 2016-11-18 | 1 | -11/+4 |
| | |||||
* | Always include an error for logging when the coordinator is marked dead (#890) | Dana Powers | 2016-11-18 | 2 | -9/+9 |
| | |||||
* | Args are optional in BrokerResponseError str (#889) | Dana Powers | 2016-11-18 | 1 | -3/+3 |
| | |||||
* | :wPass timestamp into Message, not just mimic it (#875) | Taras Voinarovskyi | 2016-11-18 | 1 | -2/+6 |
| | |||||
* | Always check for request timeouts (#887) | Dana Powers | 2016-11-18 | 2 | -4/+12 |
| | | | | * Check for requests that timeout without causing a socket read/write event | ||||
* | typo (#883) | sharego | 2016-11-15 | 1 | -1/+1 |
| | | | type error | ||||
* | Update param in warning (#878) | Dana Powers | 2016-11-14 | 1 | -2/+2 |
|\ | | | | | In Kafka 9, advertised.host.name was renamed to advertised.listeners | ||||
| * | Update param in warning | Jeff Widman | 2016-11-11 | 1 | -2/+2 |
| | | | | | | In Kafka 9, advertised.host.name was renamed to advertised.listeners | ||||
* | | Remove old design notes from Kafka 8 era (#876) | Jeff Widman | 2016-11-14 | 1 | -32/+0 |
| | | |||||
* | | Fix typos (#874) | Dana Powers | 2016-11-14 | 12 | -18/+18 |
|\ \ | |/ |/| | |||||
| * | Fix typos | Jeff Widman | 2016-11-14 | 12 | -18/+18 |
|/ | |||||
* | Revert consumer iterators from max_poll_records (#856) | Dana Powers | 2016-10-24 | 2 | -14/+180 |
| |