summaryrefslogtreecommitdiff
Commit message (Expand)AuthorAgeFilesLines
...
| * | Check response.error for async producerViktor Shlapakov2015-06-033-21/+27
| * | Async producer: py2.6 backward compatibility fixViktor Shlapakov2015-06-031-2/+2
| * | Improve async producer code: logic and style fixesViktor Shlapakov2015-06-035-76/+75
| * | Increase producer test timeoutViktor Shlapakov2015-06-031-1/+1
| * | Change backoff message log levelViktor Shlapakov2015-06-031-1/+1
| * | Fix async producer queue put argumentsViktor Shlapakov2015-06-031-2/+4
| * | Fix names for async retries opts, add timeout for putViktor Shlapakov2015-06-034-20/+34
| * | Simplification of retry logicViktor Shlapakov2015-06-032-31/+29
| * | Fix small issues with names/testsViktor Shlapakov2015-06-033-16/+16
| * | async queue: refactored code; add one more testEduard Iskandarov2015-06-032-4/+23
| * | add producer send batch queue overfilled testИскандаров Эдуард2015-06-032-2/+24
| * | Disable retry on timeouts by default (old behaviour)Viktor Shlapakov2015-06-031-1/+1
| * | Clean and simplify retry logicViktor Shlapakov2015-06-033-63/+54
| * | Arg fixes for base/keyed producersViktor Shlapakov2015-06-032-4/+2
| * | Improved retry logicViktor Shlapakov2015-06-035-34/+76
| * | Fixed tests and other issues after rebaseViktor Shlapakov2015-06-033-32/+20
| * | Returned default behaviour with no retriesViktor Shlapakov2015-06-031-1/+1
| * | Fix: check failed reqs to retry only for positive limitViktor Shlapakov2015-06-031-3/+3
| * | Fixed compatible issues with testsViktor Shlapakov2015-06-032-15/+16
| * | Producer _send_upstream fixes, added tests for retriesViktor Shlapakov2015-06-032-6/+157
| * | Fixed base producer importsViktor Shlapakov2015-06-031-1/+2
| * | Retries for async batchingViktor Shlapakov2015-06-034-15/+50
|/ /
* | Merge pull request #342 from wting/fix_consumer_falsinessDana Powers2015-05-171-4/+4
|\ \ | |/ |/|
| * Check vs None directly.William Ting2015-05-171-4/+4
|/
* Merge pull request #376 from hellais/fix/offsetDana Powers2015-05-141-1/+1
|\
| * Fix calling of _offsetsArturo Filastò2015-05-141-1/+1
|/
* Merge pull request #367 from dpkp/clean_metadata_refreshDana Powers2015-04-121-13/+14
|\
| * Update debug log messages in client.load_metadata_for_topicsDana Powers2015-04-121-2/+2
| * clean local metadata before requesting refresh in load_metadata_for_topics()Dana Powers2015-04-121-2/+7
| * Simplify client.reset_topic_metadataDana Powers2015-04-121-9/+5
* | Merge pull request #366 from dpkp/failed_payloadsDana Powers2015-04-121-79/+77
|\ \ | |/ |/|
| * Improve send_produce_request docstringDana Powers2015-04-061-6/+17
| * Add debug logging for all broker-aware requests/responsesDana Powers2015-04-061-0/+3
| * Refactor KafkaClient._send_broker_aware_request to return a list of responsesDana Powers2015-04-061-73/+57
* | Merge pull request #365 from dpkp/kafka_consumer_fixupDana Powers2015-04-061-28/+32
|\ \ | |/ |/|
| * Use kafka_bytestring when decoding message topics in KafkaConsumer.fetch_mess...Dana Powers2015-04-041-18/+22
| * Use list comprehension on _topics in KafkaConsumer.fetch_messagesDana Powers2015-04-041-8/+8
| * call _consume_topic_partition() before storing offsetDana Powers2015-04-041-1/+1
| * Fix python3 str/bytes bug in KafkaConsumer.set_topic_partitions({(topic, part...Dana Powers2015-04-041-1/+1
|/
* Merge pull request #360 from dpkp/atexit_cleanupDana Powers2015-04-042-4/+51
|\
| * Register atexit handlers for consumer and producer thread/multiprocess cleanu...Dana Powers2015-03-312-4/+51
* | Merge pull request #361 from kecaps/masterDana Powers2015-04-0411-49/+69
|\ \ | |/ |/|
| * Make external API consistently support python3 strings for topic.Space2015-04-0311-49/+69
|/
* Merge pull request #356 from dpkp/always_fetch_offsetsDana Powers2015-03-305-14/+105
|\
| * Bulk fetch offset partitions in base consumer -- suggested by ecanzonieriDana Powers2015-03-301-8/+9
| * Fetch previously committed offsets in base consumer class so long asDana Powers2015-03-305-14/+34
| * Skip these tests: no OffsetCommitRequest for 0.8.0Viktor Shlapakov2015-03-301-2/+2
| * Added basic tests for load_initial_offsets optionViktor Shlapakov2015-03-301-0/+35
| * Add test case for MP Consumer auto commitAli-Akber Saifee2015-03-301-0/+35
* | Merge pull request #355 from dpkp/correlation_id_moduloDana Powers2015-03-302-7/+15
|\ \ | |/ |/|
View Lorry Controller Status