| Commit message (Collapse) | Author | Age | Files | Lines | ||
|---|---|---|---|---|---|---|
| ... | ||||||
| | * | Update KafkaConsumer to handle request-specific FailedPayloadsErrors | Dana Powers | 2015-06-08 | 1 | -11/+13 | |
| | | | ||||||
| * | | Merge pull request #396 from dpkp/sync_producer_fail_on_error_kwarg | Dana Powers | 2015-06-09 | 2 | -4/+30 | |
| |\ \ | | | | | | | Sync producer fail on error kwarg | |||||
| | * | | Support sync_fail_on_error kwarg in Producer | Dana Powers | 2015-06-09 | 2 | -4/+30 | |
| |/ / | ||||||
| * | | Create a new child thread on each open fixture try | Dana Powers | 2015-06-09 | 1 | -6/+7 | |
| | | | ||||||
| * | | Merge pull request #397 from dpkp/test_logging | Dana Powers | 2015-06-09 | 6 | -17/+36 | |
| |\ \ | | | | | | | Test logging | |||||
| | * | | Dont try to terminate a child that has already exited in test/service _despawn | Dana Powers | 2015-06-08 | 1 | -1/+2 | |
| | | | | ||||||
| | * | | Produce messages to both partitions in async producer leader switch test | Dana Powers | 2015-06-08 | 1 | -1/+9 | |
| | | | | ||||||
| | * | | Reduce blocking times in consumer integration tests | Dana Powers | 2015-06-08 | 1 | -14/+14 | |
| | | | | ||||||
| | * | | Reduce log chatter in tests (only debug kafka.conn in test_conn) | Dana Powers | 2015-06-08 | 2 | -0/+10 | |
| | | | | ||||||
| | * | | Fail fast in nosetests | Dana Powers | 2015-06-08 | 1 | -1/+1 | |
| | |/ | ||||||
| * | | Merge pull request #401 from dpkp/async_producer_responses | Dana Powers | 2015-06-09 | 2 | -12/+60 | |
| |\ \ | |/ |/| | Async producer responses | |||||
| | * | Use a list, not request_tries.keys(), to track requests / responses in async ↵ | Dana Powers | 2015-06-09 | 1 | -2/+4 | |
| | | | | | | | | | producer | |||||
| | * | Add Unit test for async producer leader change; return ProduceResponse on ↵ | Dana Powers | 2015-06-09 | 1 | -10/+56 | |
| |/ | | | | success | |||||
| * | Merge pull request #394 from dpkp/cleanups | Dana Powers | 2015-06-08 | 8 | -152/+88 | |
| |\ | | | | | Cleanups | |||||
| | * | Fixup for loop vars in kafka/protocol.py | Dana Powers | 2015-06-08 | 1 | -14/+14 | |
| | | | ||||||
| | * | Improve kafka client debug request/response logging | Dana Powers | 2015-06-08 | 1 | -5/+5 | |
| | | | ||||||
| | * | 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 | |
| | | | | | ||||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |