| Commit message (Collapse) | Author | Age | Files | Lines | ||
|---|---|---|---|---|---|---|
| ... | ||||||
| | * | Prefer single quotes for strings | Dana Powers | 2015-06-08 | 1 | -14/+12 | |
| | | | ||||||
| | * | Add a few extra docstring comments about thread-safe clients/connections | Dana Powers | 2015-06-08 | 3 | -5/+12 | |
| | | | ||||||
| | * | Dont maintain all producer args / kwargs in subclass __init__ and docstrings ↵ | Dana Powers | 2015-06-08 | 2 | -91/+24 | |
| | | | | | | | | | -- just refer to super class (Producer) | |||||
| | * | Cleanup imports in kafka/client and kafka/consumer | Dana Powers | 2015-06-08 | 3 | -23/+21 | |
| | | | ||||||
| * | | Import style nits in integration tests | Dana Powers | 2015-06-08 | 4 | -7/+10 | |
| | | | ||||||
| * | | Add zk to KafkaIntegrationTestCase attributes to fix lint error | Dana Powers | 2015-06-08 | 1 | -0/+1 | |
| | | | ||||||
| * | | Dump fixture logs on OffsetResponse error during producer integration | Dana Powers | 2015-06-08 | 1 | -3/+9 | |
| | | | | | | | | | | | tests. This is intended to help debug an intermittent failure that requires server logs. | |||||
| * | | Retry with shorter 5sec timeout when trying to open() fixtures | Dana Powers | 2015-06-08 | 2 | -7/+14 | |
| |/ | | | | | - this is intended to reduce flapping tests caused by intermittent - fixture startup issues on travis-ci | |||||
| * | Merge pull request #389 from dpkp/task_done_key_error | Dana Powers | 2015-06-08 | 1 | -2/+10 | |
| |\ | | | | | KafkaConsumer.task_done: warn and skip unrecognized topic-partitions | |||||
| | * | KafkaConsumer.task_done - warn and skip messages from unrecognized ↵ | Dana Powers | 2015-06-06 | 1 | -2/+10 | |
| | | | | | | | | | topic-partitions | |||||
| * | | Merge pull request #393 from dpkp/simple_consumer_leader_change | Dana Powers | 2015-06-08 | 2 | -2/+78 | |
| |\ \ | | | | | | | Simple consumer leader change | |||||
| | * | | SimpleConsumer should refresh metadata and retry on leadership changes; only ↵ | Dana Powers | 2015-06-08 | 1 | -1/+4 | |
| | | | | | | | | | | | | | raise on UnknownTopicOrPartition | |||||
| | * | | Add unit tests for SimpleConsumer error handling | Dana Powers | 2015-06-08 | 1 | -1/+74 | |
| |/ / | ||||||
| * | | Merge pull request #380 from dpkp/multiprocess_consumer_partitions | Dana Powers | 2015-06-08 | 2 | -5/+18 | |
| |\ \ | | | | | | | Support optional partitions kwarg in MultiProcessConsumer | |||||
| | * | | Support optional partitions kwarg in MultiProcessConsumer | Dana Powers | 2015-05-17 | 2 | -5/+18 | |
| | | | | ||||||
| * | | | Merge pull request #379 from dpkp/deprecate_keyed_producer_send | Dana Powers | 2015-06-08 | 3 | -17/+18 | |
| |\ \ \ | | | | | | | | | Deprecate KeyedProducer.send in favor of send_messages | |||||
| | * | | | Deprecate KeyedProducer.send in favor of send_messages -- keep interface ↵ | Dana Powers | 2015-05-17 | 3 | -17/+18 | |
| | | | | | | | | | | | | | | | | | consistent | |||||
| * | | | | Merge pull request #392 from reAsOn2010/fix-uncaught-FailedPayloadsError | Dana Powers | 2015-06-08 | 3 | -1/+18 | |
| |\ \ \ \ | | | | | | | | | | | try to fix uncaught FailedPayloadsError in consumer | |||||
| | * | | | | try to fix uncaught FailedPayloadsError | reAsOn2010 | 2015-06-09 | 3 | -1/+18 | |
| |/ / / / | ||||||
| * | | | | Respawn crashed services in test/service.py, rather than raise RuntimeError | Dana Powers | 2015-06-07 | 1 | -12/+26 | |
| | | | | | ||||||
| * | | | | Merge pull request #388 from dpkp/331_fixups | Dana Powers | 2015-06-06 | 6 | -110/+180 | |
| |\ \ \ \ | | | | | | | | | | | async producer fixups | |||||
| | * | | | | Add async_stop_timeout parameter to tune how long to let the producer | Dana Powers | 2015-06-06 | 1 | -3/+26 | |
| | | | | | | | | | | | | | | | | | | | | | | | | | | keep trying to send messages before timing out. Log an error if async producer was stopped before all messages sent. | |||||
| | * | | | | Dont stop async producer until all pending messages have been processed | Dana Powers | 2015-06-06 | 1 | -1/+1 | |
| | | | | | | ||||||
| | * | | | | Update Producer class docstring | Dana Powers | 2015-06-06 | 1 | -4/+25 | |
| | | | | | | ||||||
| | * | | | | Deprecate async producer batch_send kwarg -- use 'async' instead | Dana Powers | 2015-06-06 | 6 | -46/+47 | |
| | | | | | | ||||||
| | * | | | | Log retries and failed messages in async producer (configurable as full ↵ | Dana Powers | 2015-06-06 | 1 | -12/+24 | |
| | | | | | | | | | | | | | | | | | | | | | messages or hash()) | |||||
| | * | | | | PR 331 fixup: do not attempt to get new messages if there are pending retries | Dana Powers | 2015-06-06 | 1 | -4/+9 | |
| | | | | | | ||||||
| | * | | | | PR 331 fixup: Rename reqs dict to request_tries | Dana Powers | 2015-06-06 | 1 | -9/+13 | |
| | | | | | | ||||||
| | * | | | | PR 331 fixup: Dont need try/except when calling send_produce_requests with ↵ | Dana Powers | 2015-06-06 | 1 | -15/+16 | |
| | | | | | | | | | | | | | | | | | | | | | fail_on_error=False | |||||
| | * | | | | PR 331 fixup: log warnings on async producer backoff and metadata refresh | Dana Powers | 2015-06-06 | 1 | -1/+2 | |
| | | | | | | ||||||
| | * | | | | PR 331 fixup: Support unlimited retries with async_retry_limit=None | Dana Powers | 2015-06-06 | 1 | -6/+8 | |
| | | | | | | | | | | | | | | | | | | | | | Async producer defaults are now retry everything always w/ 100ms backoff | |||||
| | * | | | | PR 331 fixup: fix _handle_error closure | Dana Powers | 2015-06-06 | 1 | -16/+17 | |
| | | | | | | ||||||
| | * | | | | PR 331 fixup: Fix kafka.common imports from kafka.producer.base (one import ↵ | Dana Powers | 2015-06-06 | 1 | -3/+2 | |
| |/ / / / | | | | | | | | | | | | | block, add ProduceResponse) | |||||
| * | | | | Encode random_message strings to bytes in test_failover_integration | Dana Powers | 2015-06-06 | 1 | -1/+2 | |
| | | | | | ||||||
| * | | | | KafkaClient should try/except ConnnectionError when calling _get_conn | Dana Powers | 2015-06-06 | 1 | -2/+2 | |
| | | | | | ||||||
| * | | | | Small hanging indent style nits in some producer integration tests | Dana Powers | 2015-06-06 | 1 | -4/+8 | |
| | | | | | ||||||
| * | | | | Sleep for 500ms before retrying consumer pending call in tests | Dana Powers | 2015-06-06 | 1 | -0/+1 | |
| | | | | | ||||||
| * | | | | test_batched_simple_producer__triggers_by_message should wait for producer ↵ | Dana Powers | 2015-06-06 | 1 | -0/+10 | |
| | | | | | | | | | | | | | | | | | queue to drain before testing messages were sent | |||||
| * | | | | Include message number in sent message value in _send_random_message | Dana Powers | 2015-06-06 | 1 | -1/+1 | |
| | | | | | ||||||
| * | | | | add option to check for at-least-once message delivery in failover tests | Dana Powers | 2015-06-06 | 1 | -6/+12 | |
| | | | | | ||||||
| * | | | | Reenable test_switch_leader_async | Dana Powers | 2015-06-06 | 1 | -7/+13 | |
| | | | | | ||||||
| * | | | | FailedPayloadsError now only has a single payload; use .payload attribute | Dana Powers | 2015-06-06 | 2 | -4/+4 | |
| | | | | | | | | | | | | | | | | | .failed_payloads attribute has been removed. | |||||
| * | | | | random_string helper should return str not bytes | Dana Powers | 2015-06-06 | 4 | -17/+16 | |
| | | | | | ||||||
| * | | | | Raise an error if we attempt to group duplicate topic-partition payloads | Dana Powers | 2015-06-06 | 3 | -1/+10 | |
| | | | | | | | | | | | | | | | | | - previously this would simply drop one of the payloads | |||||
| * | | | | Module loggers in test/fixtures and test/service | Dana Powers | 2015-06-06 | 2 | -27/+35 | |
| | | | | | ||||||
| * | | | | Use separate module loggers instead of a single 'kafka' logger | Dana Powers | 2015-06-06 | 9 | -9/+17 | |
| | |_|/ |/| | | ||||||
| * | | | Fix import error in kafka/producer/base.py | Dana Powers | 2015-06-06 | 1 | -1/+1 | |
| | | | | ||||||
| * | | | Merge pull request #387 from dpkp/no_runtime_version_check | Dana Powers | 2015-06-04 | 5 | -8/+5 | |
| |\ \ \ | | | | | | | | | Dont get __version__ from pkg_resources | |||||
| | * | | | Set __version__ string in kafka/version.py | Dana Powers | 2015-06-04 | 5 | -8/+5 | |
| |/ / / | ||||||
| * | | | Merge pull request #331 from vshlapakov/feature-producer-retries | Dana Powers | 2015-06-04 | 6 | -29/+296 | |
| |\ \ \ | |_|/ |/| | | Async producer retries for failed messages | |||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |