| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Cleanup new producer tests...async_producer_connect_errors | Dana Powers | 2015-12-04 | 1 | -6/+6 |
| | | |||||
| * | new pylint disables for pylint 1.5.1 | Zack Dever | 2015-12-02 | 1 | -1/+1 |
| | | | | | | tested locally with `pylint --rcfile=pylint.rc -E kafka test`. should pass travis builds. | ||||
| * | Merge pull request #420 from toddpalino/master | Dana Powers | 2015-12-02 | 1 | -1/+29 |
| |\ | | | | | Initial support for consumer coordinator | ||||
| | * | Fix misnamed node to nodeId in test | tpalino | 2015-07-02 | 1 | -1/+1 |
| | | | |||||
| | * | Add missing import for ConsumerMetadataResponse | tpalino | 2015-07-01 | 1 | -1/+1 |
| | | | |||||
| | * | Support consumer metadata requests | tpalino | 2015-07-01 | 1 | -0/+28 |
| | | | | | | | | | | | | | Support added for ConsumerMetadataRequest and ConsumerMetadataResponse Added consumer-aware request routine for supporting the consumer coordinator Added separate client method for fetching Kafka-committed offsets from the coordinator | ||||
| * | | 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 |
| | | | |||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |