| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Do not re-close a disconnected connectionconnection_error_close | Dana Powers | 2017-01-07 | 1 | -1/+0 |
| | | |||||
| * | Drop unused last_failure time from BrokerConnection | Dana Powers | 2017-01-07 | 1 | -4/+1 |
| | | |||||
| * | Use connection state functions where possible | Dana Powers | 2017-01-07 | 2 | -3/+4 |
| | | |||||
| * | Pass error to BrokerConnection.close() | Dana Powers | 2017-01-07 | 2 | -20/+28 |
| | | |||||
| * | 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 |
| | | |||||
| * | Fix murmur2 bug handling python2 bytes that do not ascii encode (#815) | Dana Powers | 2016-10-22 | 3 | -27/+20 |
| | | | | | | | * Add test for murmur2 py2 bytes bug * Fix murmur2 handling of python2 bytes * Drop bytearray / str / unicode MurmurPartitioner tests -- no longer supported * Make DefaultPartitioner importable from kafka.partitioner | ||||
| * | Bugfix on max_poll_records - TypeError: object of type NoneType has no len() | Dana Powers | 2016-10-04 | 1 | -1/+1 |
| | | |||||
| * | KAFKA-3007: KafkaConsumer max_poll_records (#831) | Dana Powers | 2016-09-28 | 5 | -262/+123 |
| | | |||||
| * | Update Partitioners for use with KafkaProducer (#827) | barrotsteindev | 2016-09-28 | 5 | -24/+112 |
| | | |||||
| * | Monkeypatch max_in_flight_requests_per_connection when checking broker ↵ | Dana Powers | 2016-09-28 | 1 | -6/+11 |
| | | | | | version (#834) | ||||
| * | Fix message timestamp_type (#828) | Josh Yudaken | 2016-09-15 | 1 | -1/+4 |
| | | |||||
| * | Added ssl_password config option to KafkaProducer class, identical to… (#830) | kierkegaard13 | 2016-09-15 | 2 | -0/+5 |
| | | | | | | | | | * Added ssl_password config option to KafkaProducer class, identical to option in KafkaConsumer class * removed non-ascii characters * changed - to : in comments | ||||
| * | from kafka import ConsumerRebalanceListener, OffsetAndMetadata | Dana Powers | 2016-09-04 | 1 | -1/+2 |
| | | |||||
| * | Fix quota violation exception message (#809) | Dana Powers | 2016-08-20 | 1 | -4/+4 |
| | | |||||
| * | Improve KafkaProducer docstring re retries config | Dana Powers | 2016-08-20 | 1 | -3/+5 |
| | | |||||
| * | Add comment for round robin partitioner with different subscriptions | Dana Powers | 2016-08-20 | 1 | -0/+15 |
| | | |||||
| * | Use 0.10.0.1 for integration tests (#803) | Dana Powers | 2016-08-11 | 6 | -5/+193 |
| | | | | | | | * Add 0.10.0.1 fixture resources * Use new release 0.10.0.1 for 0.10 testing | ||||
| * | Bump version for development | Dana Powers | 2016-08-11 | 1 | -1/+1 |
| | | |||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |