summaryrefslogtreecommitdiff
Commit message (Expand)AuthorAgeFilesLines
...
| * Add sphinx_rtd_theme to docs requirements.txtDana Powers2015-03-291-0/+1
| * Updates to KafkaConsumer usage docsDana Powers2015-03-291-42/+26
| * fixup kafka consumer docstringDana Powers2015-03-291-1/+1
| * Move KafkaConsumer usage examples to docs/usage; Put KeyedProducer usage righ...Dana Powers2015-03-291-14/+105
| * Improve KafkaConsumer docstringsDana Powers2015-03-291-134/+94
|/
* Merge pull request #340 from dpkp/deprecate_metadata_broker_listDana Powers2015-03-291-8/+26
|\
| * Deprecate KafkaConsumer config metadata_broker_list in favor of bootstrap_ser...Dana Powers2015-03-231-8/+26
* | Merge pull request #336 from scrapinghub/feature-mp-consumer-paramsDana Powers2015-03-295-38/+57
|\ \
| * | Manageable queue.put() operation for MPConsumer processesViktor Shlapakov2015-03-252-4/+12
| * | Added pylint.rc: ignoring SyncManager for pylintViktor Shlapakov2015-03-242-1/+3
| * | Using mp.manager to solve the issue with join for MPConsumerViktor Shlapakov2015-03-241-6/+7
| * | Moving to **kwargs for MPConsumer optionsViktor Shlapakov2015-03-242-6/+5
| * | Using iter_timeout=0 for MP inner consumer in testsViktor Shlapakov2015-03-131-1/+4
| * | Moved additional MP consumer options to **kwargsViktor Shlapakov2015-03-131-3/+3
| * | Using additional params for MP consumer child processViktor Shlapakov2015-03-131-26/+32
* | | Merge pull request #350 from ecanzonieri/enable_commit_on_seekDana Powers2015-03-291-1/+1
|\ \ \
| * | | Increase count_since_commit on seekEnrico Canzonieri2015-03-201-1/+1
| |/ /
* | | Merge pull request #338 from dpkp/structs_reorgDana Powers2015-03-291-23/+26
|\ \ \
| * | | Fixup indentation in kafka/common.py; add links to protocol definitionsDana Powers2015-03-081-23/+26
| | |/ | |/|
* | | Merge pull request #337 from dpkp/gzip_contextDana Powers2015-03-291-23/+32
|\ \ \
| * | | Take the linter to kafka/codec.pyDana Powers2015-03-091-11/+10
| * | | Gzip context manager not supported in py2.6, so use try/finally insteadDana Powers2015-03-091-2/+17
| * | | Use context managers in gzip_encode / gzip_decodeDana Powers2015-03-081-12/+7
| |/ /
* | | Merge pull request #329 from vshlapakov/feature-batch-msg-keysDana Powers2015-03-294-16/+76
|\ \ \ | |_|/ |/| |
| * | Correct message keys for async batching modeViktor Shlapakov2015-02-254-16/+76
* | | Merge pull request #335 from scrapinghub/fix-mp-consumer-distributionDana Powers2015-03-121-10/+12
|\ \ \ | |_|/ |/| |
| * | Used thread-safe dict.copy().keys() for MP consumer partitionsViktor Shlapakov2015-03-121-1/+4
| * | Cleaned code for MP consumer chunkingViktor Shlapakov2015-03-111-10/+9
| * | Fixing distribution for MP ConsumerViktor Shlapakov2015-03-031-1/+1
| |/
* | Merge branch 'vshlapakov-feature-async-threading'Dana Powers2015-03-083-26/+73
|\ \
| * | Async producer stop() fixViktor Shlapakov2015-02-261-2/+2
| * | Using threading.Event to stop async producer threadViktor Shlapakov2015-02-261-5/+10
| * | Returned original tests, rm dirty flag, name fixesViktor Shlapakov2015-02-253-25/+61
| * | Make KafkaConnection copies usable across threadsAlexey Borzenkov2015-02-251-0/+4
| * | Trying to use threading for async batchingViktor Shlapakov2015-02-251-3/+5
* | | Merge branch 'jobevers-master'Dana Powers2015-03-081-1/+3
|\ \ \
| * | | Add failed_payloads attribute to FailedPayloadsErrorJob Evers2015-03-081-1/+3
* | | | Merge pull request #332 from dpkp/kafka_client_editsDana Powers2015-03-072-14/+11
|\ \ \ \
| * | | | KafkaClient.get_partition_ids_for_topic now returns empty list for unknown to...Dana Powers2015-03-021-1/+1
| * | | | Add comment about no server response case in _send_broker_aware_requestDana Powers2015-03-021-0/+5
| * | | | Avoid topic_partitions KeyError in KafkaClientDana Powers2015-03-021-1/+1
| * | | | Remove KafkaConsumer.BYTES_CONFIGURATION_KEYSDana Powers2015-03-011-11/+2
| * | | | Accept KafkaClient client_id as string or bytes; encode string client_id as u...Dana Powers2015-03-011-1/+2
| | |_|/ | |/| |
* | | | Merge pull request #324 from chmduquesne/masterDana Powers2015-03-022-0/+9
|\ \ \ \
| * | | | Stopping daemonized threads when references to these threads are lostChristophe-Marie Duquesne2015-03-022-0/+9
| |/ / /
* | | | Merge pull request #328 from wkiser/validate_offsetDana Powers2015-03-022-0/+8
|\ \ \ \
| * | | | Fixes consumer/kafka and consumer/simple to only yield messages if the messag...wkiser2015-03-022-0/+8
| |/ / /
* | | | Merge pull request #296 from ecanzonieri/validate_consumer_offsetDana Powers2015-03-022-4/+97
|\ \ \ \ | |/ / / |/| | |
| * | | Retry failed partitions and add integration testsEnrico Canzonieri2015-01-262-1/+45
| * | | Merge branch 'master' of github.com:mumrah/kafka-python into validate_consume...Enrico Canzonieri2015-01-2635-596/+1652
| |\ \ \
View Lorry Controller Status