| Commit message (Collapse) | Author | Age | Files | Lines | ||
|---|---|---|---|---|---|---|
| ... | ||||||
| * | | Merge pull request #473 from ecanzonieri/use_unblocking_io_for_aware_requests | Dana Powers | 2015-12-02 | 1 | -0/+17 | |
| |\ \ | | | | | | | Use unblocking io for broker aware requests | |||||
| | * | | Add tests. Bug fix. Rename socket_conn dict. | Enrico Canzonieri | 2015-11-10 | 1 | -0/+17 | |
| | |/ | ||||||
| * | | Merge pull request #457 from saaros/block-for-number-of-messages | Dana Powers | 2015-12-02 | 1 | -0/+18 | |
| |\ \ | | | | | | | Consumers get_messages: allow blocking until some messages are received | |||||
| | * | | Consumers get_messages: allow blocking until some messages are received | Oskari Saarenmaa | 2015-09-18 | 1 | -0/+18 | |
| | |/ | | | | | | | | | | | | | | | | | Modified MultiProcessConsumer's and SimpleConsumer's `block` argument to allow integer value which defines the number of messages to block for. This allows callers to ask for a high number of messages and block only until some of them are received. Otherwise callers would have to request messages one by one or block for some time. | |||||
| * | | Merge pull request #439 from chrischamberlin/fix-murmur | Dana Powers | 2015-12-02 | 1 | -0/+23 | |
| |\ \ | | | | | | | Fix translation of Java murmur2 code, fix byte encoding for Python 3. | |||||
| | * | | Fix translation of Java murmur2 code, fix byte encoding for Python 3. | Chris Chamberlin | 2015-07-28 | 1 | -0/+23 | |
| | |/ | | | | | | | | | | | Avoid further type changes when Murmur2Partitioner is passed a byte array. Change leftover-bytes logic to match the Java switch statement, and add tests to verify that partition selection matches Java implementation. | |||||
| * | | Merge pull request #435 from docker-hub/fix-producer-cleanup-logic | Dana Powers | 2015-12-02 | 1 | -0/+14 | |
| |\ \ | | | | | | | Reworked the if statement logic to only call stop() on not-stopped producer objects | |||||
| | * | | Fixing https://github.com/mumrah/kafka-python/issues/434 | toli | 2015-07-24 | 1 | -0/+14 | |
| | | | | | | | | | | | | | | | | Reworked the if statement logic to only call stop() on not-stopped objects. added tests | |||||
| * | | | Merge pull request #409 from scrapinghub/feature-allow-null-payload | Dana Powers | 2015-12-02 | 2 | -2/+44 | |
| |\ \ \ | |_|/ |/| | | Allow null payload for deletion feature | |||||
| | * | | Producer test fix for python3 | Viktor Shlapakov | 2015-06-17 | 1 | -1/+1 | |
| | | | | ||||||
| | * | | Add KeyedProducer test with null payloads | Viktor Shlapakov | 2015-06-17 | 1 | -0/+22 | |
| | | | | ||||||
| | * | | Add basic keyed producer tests | Viktor Shlapakov | 2015-06-17 | 1 | -2/+22 | |
| | | | | ||||||
| * | | | fix #410 SimpleConsumer cannot seek to an absolute offset. | haosdent | 2015-06-20 | 1 | -0/+14 | |
| | |/ |/| | ||||||
| * | | Increase timeout and backoff when retrying spawn of test fixtures | Dana Powers | 2015-06-11 | 1 | -2/+16 | |
| | | | ||||||
| * | | Merge pull request #402 from dpkp/kafka_0_8_2_1 | Dana Powers | 2015-06-10 | 2 | -6/+6 | |
| |\ \ | | | | | | | Use kafka 0.8.2.1 in integration tests | |||||
| | * | | Add kafka 0.8.2.1 to integration tests, remove 0.8.2.0 | Dana Powers | 2015-06-10 | 2 | -6/+6 | |
| | | | | ||||||
| * | | | Merge pull request #404 from dpkp/consumer_more_exception_handling | Dana Powers | 2015-06-10 | 1 | -2/+42 | |
| |\ \ \ | |/ / |/| | | Consumer - handle exceptions in commit() and reset_partition_offset() | |||||
| | * | | (test) SimpleConsumer.reset_partition_offset should not raise exception on ↵ | Dana Powers | 2015-06-10 | 1 | -1/+16 | |
| | | | | | | | | | | | | | failure | |||||
| | * | | (test) Consumer commit() should log errors and return True/False, not raise ↵ | Dana Powers | 2015-06-10 | 1 | -0/+24 | |
| | | | | | | | | | | | | | exceptions | |||||
| | * | | Split consumer test class between Simple and MultiProcess | Dana Powers | 2015-06-10 | 1 | -1/+2 | |
| | | | | ||||||
| * | | | Use at_least=True when counting messages in leader failover tests | Dana Powers | 2015-06-10 | 1 | -1/+4 | |
| |/ / | ||||||
| * | | Retry failed messages in failover integration tests; use module logger | Dana Powers | 2015-06-10 | 1 | -12/+17 | |
| | | | ||||||
| * | | Remove 1 sec timeout on topic creation in client response ordering test | Dana Powers | 2015-06-10 | 1 | -2/+2 | |
| | | | ||||||
| * | | Add KafkaClient test to show that request / response ordering is broken | Dana Powers | 2015-06-10 | 1 | -1/+31 | |
| | | | ||||||
| * | | Test failover integration with 3-brokers / replicas / partitions | Dana Powers | 2015-06-09 | 1 | -3/+3 | |
| |/ | ||||||
| * | Reset kafka.conn logger level in tearDown | Dana Powers | 2015-06-09 | 1 | -0/+13 | |
| | | ||||||
| * | Support sync_fail_on_error kwarg in Producer | Dana Powers | 2015-06-09 | 1 | -2/+18 | |
| | | ||||||
| * | 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 | 5 | -16/+35 | |
| |\ | | | | | 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 | |
| | | | ||||||
| * | | Add Unit test for async producer leader change; return ProduceResponse on ↵ | Dana Powers | 2015-06-09 | 1 | -10/+56 | |
| |/ | | | | success | |||||
| * | 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 | |||||
| * | 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 | 1 | -2/+11 | |
| |\ | | | | | Support optional partitions kwarg in MultiProcessConsumer | |||||
| | * | Support optional partitions kwarg in MultiProcessConsumer | Dana Powers | 2015-05-17 | 1 | -2/+11 | |
| | | | ||||||
| * | | Merge pull request #379 from dpkp/deprecate_keyed_producer_send | Dana Powers | 2015-06-08 | 1 | -10/+10 | |
| |\ \ | | | | | | | Deprecate KeyedProducer.send in favor of send_messages | |||||
| | * | | Deprecate KeyedProducer.send in favor of send_messages -- keep interface ↵ | Dana Powers | 2015-05-17 | 1 | -10/+10 | |
| | |/ | | | | | | | consistent | |||||
| * | | try to fix uncaught FailedPayloadsError | reAsOn2010 | 2015-06-09 | 1 | -0/+8 | |
| | | | ||||||
| * | | Respawn crashed services in test/service.py, rather than raise RuntimeError | Dana Powers | 2015-06-07 | 1 | -12/+26 | |
| | | | ||||||
| * | | Deprecate async producer batch_send kwarg -- use 'async' instead | Dana Powers | 2015-06-06 | 2 | -19/+2 | |
| | | | ||||||
| * | | Encode random_message strings to bytes in test_failover_integration | Dana Powers | 2015-06-06 | 1 | -1/+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 | |||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |