Commit message (Collapse) | Author | Age | Files | Lines | ||
---|---|---|---|---|---|---|
... | ||||||
| * | Fix python3 str/bytes bug in KafkaConsumer.set_topic_partitions({(topic, ↵ | Dana Powers | 2015-04-04 | 1 | -1/+1 | |
|/ | | | | partition): offset, }) | |||||
* | Merge pull request #360 from dpkp/atexit_cleanup | Dana Powers | 2015-04-04 | 2 | -4/+51 | |
|\ | | | | | Register atexit handlers for consumer and producer thread/multiprocess cleanup | |||||
| * | Register atexit handlers for consumer and producer thread/multiprocess ↵ | Dana Powers | 2015-03-31 | 2 | -4/+51 | |
| | | | | | | | | cleanup (not __del__) | |||||
* | | Merge pull request #361 from kecaps/master | Dana Powers | 2015-04-04 | 11 | -49/+69 | |
|\ \ | |/ |/| | Make external API consistently support python3 strings for topic. | |||||
| * | Make external API consistently support python3 strings for topic. | Space | 2015-04-03 | 11 | -49/+69 | |
|/ | ||||||
* | Merge pull request #356 from dpkp/always_fetch_offsets | Dana Powers | 2015-03-30 | 5 | -14/+105 | |
|\ | | | | | fetch commit offsets in base consumer unless group is None | |||||
| * | Bulk fetch offset partitions in base consumer -- suggested by ecanzonieri | Dana Powers | 2015-03-30 | 1 | -8/+9 | |
| | | ||||||
| * | Fetch previously committed offsets in base consumer class so long as | Dana Powers | 2015-03-30 | 5 | -14/+34 | |
| | | | | | | | | | | | | | | | | a group is configured (but document that group must be None for old servers). This fixes multiprocessor consumer issue that prevented access to commit offsets if auto_commit is disabled. Also refactor fetch_last_known_offsets based on KafkaConsumer While still setting unknown offsets to 0 | |||||
| * | Skip these tests: no OffsetCommitRequest for 0.8.0 | Viktor Shlapakov | 2015-03-30 | 1 | -2/+2 | |
| | | ||||||
| * | Added basic tests for load_initial_offsets option | Viktor Shlapakov | 2015-03-30 | 1 | -0/+35 | |
| | | ||||||
| * | Add test case for MP Consumer auto commit | Ali-Akber Saifee | 2015-03-30 | 1 | -0/+35 | |
| | | | | | | | | Tweak MP Consumer test to use iterator | |||||
* | | Merge pull request #355 from dpkp/correlation_id_modulo | Dana Powers | 2015-03-30 | 2 | -7/+15 | |
|\ \ | |/ |/| | correlation_id modulo | |||||
| * | Add test for correlation_id rollover | Dana Powers | 2015-03-29 | 1 | -0/+8 | |
| | | ||||||
| * | Rollover KafkaClient correlation ids at 2**31 to keep within int32 protocol ↵ | Dana Powers | 2015-03-29 | 1 | -7/+7 | |
| | | | | | | | | encoding | |||||
* | | Merge pull request #357 from dpkp/del_consumer_stop | Dana Powers | 2015-03-30 | 1 | -0/+3 | |
|\ \ | | | | | | | Stop consumers on delete | |||||
| * | | Stop consumers on delete | Dana Powers | 2015-03-30 | 1 | -0/+3 | |
| |/ | ||||||
* | | Merge pull request #341 from dpkp/kafka_consumer_docs | Dana Powers | 2015-03-29 | 4 | -149/+185 | |
|\ \ | |/ |/| | KafkaConsumer documentation | |||||
| * | Use bootstrap_servers interface in tests | Dana Powers | 2015-03-29 | 1 | -1/+1 | |
| | | ||||||
| * | Add sphinx_rtd_theme to docs requirements.txt | Dana Powers | 2015-03-29 | 1 | -0/+1 | |
| | | ||||||
| * | Updates to KafkaConsumer usage docs | Dana Powers | 2015-03-29 | 1 | -42/+26 | |
| | | ||||||
| * | fixup kafka consumer docstring | Dana Powers | 2015-03-29 | 1 | -1/+1 | |
| | | ||||||
| * | Move KafkaConsumer usage examples to docs/usage; Put KeyedProducer usage ↵ | Dana Powers | 2015-03-29 | 1 | -14/+105 | |
| | | | | | | | | right after SimpleProducer | |||||
| * | Improve KafkaConsumer docstrings | Dana Powers | 2015-03-29 | 1 | -134/+94 | |
|/ | ||||||
* | Merge pull request #340 from dpkp/deprecate_metadata_broker_list | Dana Powers | 2015-03-29 | 1 | -8/+26 | |
|\ | | | | | Deprecate metadata_broker_list in favor of bootstrap_servers | |||||
| * | Deprecate KafkaConsumer config metadata_broker_list in favor of ↵ | Dana Powers | 2015-03-23 | 1 | -8/+26 | |
| | | | | | | | | bootstrap_servers | |||||
* | | Merge pull request #336 from scrapinghub/feature-mp-consumer-params | Dana Powers | 2015-03-29 | 5 | -38/+57 | |
|\ \ | | | | | | | Using additional params for MP consumer child process | |||||
| * | | Manageable queue.put() operation for MPConsumer processes | Viktor Shlapakov | 2015-03-25 | 2 | -4/+12 | |
| | | | ||||||
| * | | Added pylint.rc: ignoring SyncManager for pylint | Viktor Shlapakov | 2015-03-24 | 2 | -1/+3 | |
| | | | ||||||
| * | | Using mp.manager to solve the issue with join for MPConsumer | Viktor Shlapakov | 2015-03-24 | 1 | -6/+7 | |
| | | | ||||||
| * | | Moving to **kwargs for MPConsumer options | Viktor Shlapakov | 2015-03-24 | 2 | -6/+5 | |
| | | | ||||||
| * | | Using iter_timeout=0 for MP inner consumer in tests | Viktor Shlapakov | 2015-03-13 | 1 | -1/+4 | |
| | | | ||||||
| * | | Moved additional MP consumer options to **kwargs | Viktor Shlapakov | 2015-03-13 | 1 | -3/+3 | |
| | | | ||||||
| * | | Using additional params for MP consumer child process | Viktor Shlapakov | 2015-03-13 | 1 | -26/+32 | |
| | | | | | | | | | | | | | | | | | | | | | - Moved the events params to a separate param for consistency - Passing additional params to internal SimpleConsumer worker for multiprocessing high-level consumer. It allows to use non-default consumer settings (fetch_size_bytes, buffer_size, max_buffer_size). | |||||
* | | | Merge pull request #350 from ecanzonieri/enable_commit_on_seek | Dana Powers | 2015-03-29 | 1 | -1/+1 | |
|\ \ \ | | | | | | | | | Enable commit on seek | |||||
| * | | | Increase count_since_commit on seek | Enrico Canzonieri | 2015-03-20 | 1 | -1/+1 | |
| |/ / | | | | | | | | | | | | | | | | When auto_commit is False this change enables an explicit call to commit() to actually commit the offsets. Otherwise a consumer won't be able to commit until at least one message is read. | |||||
* | | | Merge pull request #338 from dpkp/structs_reorg | Dana Powers | 2015-03-29 | 1 | -23/+26 | |
|\ \ \ | | | | | | | | | Fixup indentation in kafka/common.py; add links to protocol definitions | |||||
| * | | | Fixup indentation in kafka/common.py; add links to protocol definitions | Dana Powers | 2015-03-08 | 1 | -23/+26 | |
| | |/ | |/| | ||||||
* | | | Merge pull request #337 from dpkp/gzip_context | Dana Powers | 2015-03-29 | 1 | -23/+32 | |
|\ \ \ | | | | | | | | | Use context managers in gzip_encode / gzip_decode | |||||
| * | | | Take the linter to kafka/codec.py | Dana Powers | 2015-03-09 | 1 | -11/+10 | |
| | | | | ||||||
| * | | | Gzip context manager not supported in py2.6, so use try/finally instead | Dana Powers | 2015-03-09 | 1 | -2/+17 | |
| | | | | ||||||
| * | | | Use context managers in gzip_encode / gzip_decode | Dana Powers | 2015-03-08 | 1 | -12/+7 | |
| |/ / | ||||||
* | | | Merge pull request #329 from vshlapakov/feature-batch-msg-keys | Dana Powers | 2015-03-29 | 4 | -16/+76 | |
|\ \ \ | |_|/ |/| | | Correct message keys for async batching mode | |||||
| * | | Correct message keys for async batching mode | Viktor Shlapakov | 2015-02-25 | 4 | -16/+76 | |
| | | | ||||||
* | | | Merge pull request #335 from scrapinghub/fix-mp-consumer-distribution | Dana Powers | 2015-03-12 | 1 | -10/+12 | |
|\ \ \ | |_|/ |/| | | Wrong partitions distribution logic for MP Consumer | |||||
| * | | Used thread-safe dict.copy().keys() for MP consumer partitions | Viktor Shlapakov | 2015-03-12 | 1 | -1/+4 | |
| | | | ||||||
| * | | Cleaned code for MP consumer chunking | Viktor Shlapakov | 2015-03-11 | 1 | -10/+9 | |
| | | | ||||||
| * | | Fixing distribution for MP Consumer | Viktor Shlapakov | 2015-03-03 | 1 | -1/+1 | |
| |/ | ||||||
* | | Merge branch 'vshlapakov-feature-async-threading' | Dana Powers | 2015-03-08 | 3 | -26/+73 | |
|\ \ | | | | | | | | | | | | | | | | | | | PR 330: Threading for async batching Conflicts: kafka/producer/base.py | |||||
| * | | Async producer stop() fix | Viktor Shlapakov | 2015-02-26 | 1 | -2/+2 | |
| | | | ||||||
| * | | Using threading.Event to stop async producer thread | Viktor Shlapakov | 2015-02-26 | 1 | -5/+10 | |
| | | |