| Commit message (Collapse) | Author | Age | Files | Lines | ||
|---|---|---|---|---|---|---|
| ... | ||||||
| | * | | Add some more debug logging to KafkaConnection | Dana Powers | 2014-08-19 | 1 | -0/+7 | |
| | | | | ||||||
| | * | | Initialized _dirty in KafkaConnection __init__() and set _sock to None in ↵ | Dana Powers | 2014-08-17 | 1 | -2/+4 | |
| | | | | | | | | | | | | | close() | |||||
| | * | | Call _raise_connection_error in KafkaConnection.reinit() if socket ↵ | Dana Powers | 2014-08-17 | 1 | -2/+6 | |
| | | | | | | | | | | | | | connection fails | |||||
| * | | | Merge pull request #204 from mdaniel/better-type-errors | Dana Powers | 2014-08-22 | 1 | -1/+8 | |
| |\ \ \ | | | | | | | | | Better type errors | |||||
| | * | | | Fix write_int and write_short type validation | Matthew L Daniel | 2014-08-22 | 1 | -0/+6 | |
| | | | | | | | | | | | | | | | | | It will still die, just as before, but it now includes a *helpful* error message | |||||
| | * | | | PEP8 fixes | Matthew L Daniel | 2014-08-22 | 1 | -1/+2 | |
| | |/ / | ||||||
| * | | | Merge pull request #194 from dpkp/kafka_timeout_error | Dana Powers | 2014-08-22 | 2 | -3/+7 | |
| |\ \ \ | | | | | | | | | Add KafkaTimeoutError and fix client.ensure_topic_exists | |||||
| | * | | | Add KafkaTimeoutError (used by client.ensure_topic_exists) and add a test | Dana Powers | 2014-08-14 | 2 | -3/+7 | |
| | |/ / | ||||||
| * | | | Add TravisCI config for auto deployment | David Arthur | 2014-08-22 | 1 | -1/+1 | |
| |/ / | | | | | | | Tags applied to master will now be automatically deployed on PyPI | |||||
| * | | Merge pull request #174 from wizzat/new_topic | Dana Powers | 2014-08-10 | 2 | -11/+24 | |
| |\ \ | | | | | | | Handle New Topic Creation | |||||
| | * | | Handle New Topic Creation | Mark Roberts | 2014-05-22 | 2 | -11/+24 | |
| | | | | | | | | | | | | | | | | Adds ensure_topic_exists to KafkaClient, redirects test case to use that. Fixes #113 and fixes #150. | |||||
| * | | | Set module version in separate VERSION file | Dana Powers | 2014-08-10 | 1 | -1/+3 | |
| |/ / | ||||||
| * | | Merge pull request #166 from patricklucas/teach_producers_about_compression | Dana Powers | 2014-05-19 | 3 | -22/+59 | |
| |\ \ | | | | | | | Add 'codec' parameter to Producer | |||||
| | * | | Improve error handling and tests w.r.t. codecs | Patrick Lucas | 2014-05-07 | 3 | -21/+33 | |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Add function kafka.protocol.create_message_set() that takes a list of payloads and a codec and returns a message set with the desired encoding. Introduce kafka.common.UnsupportedCodecError, raised if an unknown codec is specified. Include a test for the new function. | |||||
| | * | | Merge branch 'teach_producers_about_compression' into producer_compression | Mark Roberts | 2014-05-07 | 2 | -20/+45 | |
| | |\ \ | | | | | | | | | | | | | | | | | | | | | Conflicts: servers/0.8.0/kafka-src test/test_unit.py | |||||
| | | * | | Add 'codec' parameter to Producer | Patrick Lucas | 2014-05-03 | 2 | -20/+45 | |
| | | | | | | | | | | | | | | | | | | | | | Adds a codec parameter to Producer.__init__ that lets the user choose a compression codec to use for all messages sent by it. | |||||
| * | | | | Support IPv6 hosts and networks | Alexey Borzenkov | 2014-05-09 | 1 | -3/+1 | |
| |/ / / | ||||||
| * | | | Merge branch 'master' into add_tests | Mark Roberts | 2014-05-06 | 1 | -1/+15 | |
| |\ \ \ | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | kafka/client.py contained duplicate copies of same refactor, merged. Move test/test_integration.py changes into test/test_producer_integration. Conflicts: kafka/client.py servers/0.8.0/kafka-src test/test_integration.py | |||||
| | * \ \ | Merge pull request #139 from alexcb/master | Dana Powers | 2014-05-06 | 1 | -1/+15 | |
| | |\ \ \ | | | | | | | | | | | SimpleProducer randomization of initial round robin ordering | |||||
| | | * | | | added random_start param to SimpleProducer to enable/disable randomization ↵ | Alex Couture-Beil | 2014-04-01 | 1 | -4/+11 | |
| | | | | | | | | | | | | | | | | | | | | | of the initial partition messages are published to | |||||
| | | * | | | Changed randomization to simply randomize the initial starting partition of ↵ | Alex Couture-Beil | 2014-04-01 | 1 | -3/+7 | |
| | | | | | | | | | | | | | | | | | | | | | the sorted list of partition rather than completely randomizing the initial ordering before round-robin cycling the partitions | |||||
| | | * | | | Modified SimpleProducer to randomize the initial round robin ordering | Alex Couture-Beil | 2014-03-11 | 1 | -1/+4 | |
| | | | | | | | | | | | | | | | | | | | | | | | | | | of partitions to prevent the first message from always being published to partition 0. | |||||
| | * | | | | Fix lack of timeout support in KafkaClient and KafkaConnection | maciejkula | 2014-04-16 | 2 | -2/+2 | |
| | | |/ / | |/| | | ||||||
| * | | | | Attempt to fix travis build. Decrease complexity of service.py in favor of ↵ | Mark Roberts | 2014-05-06 | 4 | -8/+12 | |
| | | | | | | | | | | | | | | | | | in memory logging. Address code review concerns | |||||
| * | | | | Make commit() check for errors instead of simply assert no error | Mark Roberts | 2014-04-30 | 1 | -1/+1 | |
| | | | | | ||||||
| * | | | | Make BrokerRequestError a base class, make subclasses for each broker error | Mark Roberts | 2014-04-30 | 3 | -53/+113 | |
| | | | | | ||||||
| * | | | | Various fixes | Mark Roberts | 2014-04-25 | 2 | -2/+9 | |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Bump version number to 0.9.1 Update readme to show supported Kafka/Python versions Validate arguments in consumer.py, add initial consumer unit test Make service kill() child processes when startup fails Add tests for util.py, fix Python 2.6 specific bug. | |||||
| * | | | | Fix last remaining test by making autocommit more intuitive | Mark Roberts | 2014-04-24 | 1 | -1/+1 | |
| | | | | | ||||||
| * | | | | Split out kafka version environments, default tox no longer runs any ↵ | Mark Roberts | 2014-04-23 | 1 | -11/+11 | |
| | | | | | | | | | | | | | | | | | integration tests, make skipped integration also skip setupClass, implement rudimentary offset support in consumer.py | |||||
| * | | | | Fix bug in socket timeout per PR #161 by maciejkula, add test | Mark Roberts | 2014-04-19 | 1 | -1/+1 | |
| | | | | | ||||||
| * | | | | Split up and speed up producer based integration tests | Mark Roberts | 2014-04-17 | 2 | -1/+2 | |
| | | | | | ||||||
| * | | | | Refactor away _get_conn_for_broker. Fix bug in _get_conn | Mark Roberts | 2014-04-09 | 1 | -13/+6 | |
| | | | | | ||||||
| * | | | | Merge branch 'master' into add_tests | Mark Roberts | 2014-04-08 | 1 | -0/+4 | |
| |\ \ \ \ | |/ / / | ||||||
| | * | | | Commit in seek if autocommit | Mark Roberts | 2014-03-27 | 1 | -1/+4 | |
| | | | | | ||||||
| | * | | | Make seek(); commit(); work without commit discarding the seek change | Mark Roberts | 2014-03-25 | 1 | -0/+1 | |
| | | | | | ||||||
| * | | | | Reinstate test_integrate, make test_protocol more explicit, create testutil | Mark Roberts | 2014-04-08 | 1 | -1/+1 | |
| | | | | | ||||||
| * | | | | Explicit testing of protocol errors. Make tests more explicit, and start ↵ | Mark Roberts | 2014-04-08 | 2 | -4/+7 | |
| |/ / / | | | | | | | | | | working on intermittent failures in test_encode_fetch_request and test_encode_produc_request | |||||
| * | | | Merge pull request #134 from wizzat/conn_refactorv0.9.0 | Dana Powers | 2014-03-21 | 3 | -26/+35 | |
| |\ \ \ | | | | | | | | | conn.py performance improvements, make examples work, add another example | |||||
| | * \ \ | Merge branch 'master' into conn_refactor | Mark Roberts | 2014-03-18 | 2 | -5/+5 | |
| | |\ \ \ | ||||||
| | * \ \ \ | Merge branch 'master' into conn_refactor | Mark Roberts | 2014-02-26 | 3 | -9/+46 | |
| | |\ \ \ \ | | | | | | | | | | | | | | | | | | | | | | | | | Conflicts: example.py | |||||
| | * | | | | | Fix grammar in error string | Mark Roberts | 2014-02-25 | 1 | -1/+1 | |
| | | | | | | | ||||||
| | * | | | | | Minor refactor in conn.py, update version in __init__.py, add ErrorString | Mark Roberts | 2014-02-25 | 3 | -26/+35 | |
| | | | | | | | ||||||
| * | | | | | | Merge pull request #109 from mrtheb/develop | Dana Powers | 2014-03-21 | 2 | -10/+29 | |
| |\ \ \ \ \ \ | |_|_|/ / / |/| | | | | | TopicAndPartition fix when partition has no leader = -1 | |||||
| | * | | | | | Merge branch 'master' into develop | mrtheb | 2014-03-17 | 5 | -15/+144 | |
| | |\ \ \ \ \ | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Conflicts: test/test_unit.py | |||||
| | * | | | | | | Changes based on comments by @rdiomar, plus added LeaderUnavailableError for ↵ | mrtheb | 2014-02-15 | 2 | -4/+11 | |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | clarity | |||||
| | * | | | | | | check for broker None in send_broker_aware_request (added test for it) | mrtheb | 2014-01-31 | 1 | -5/+14 | |
| | | | | | | | | ||||||
| | * | | | | | | Merge branch 'master' into develop | mrtheb | 2014-01-31 | 2 | -74/+114 | |
| | |\ \ \ \ \ \ | | | |_|_|_|/ | | |/| | | | | ||||||
| | * | | | | | | Handle cases for partition with leader=-1 (not defined) | Marc Labbe | 2014-01-31 | 2 | -10/+12 | |
| | | | | | | | | ||||||
| | * | | | | | | added mock | mrtheb | 2014-01-18 | 1 | -3/+4 | |
| | | | | | | | | ||||||
| * | | | | | | | Check against basestring instead of str in collect.hosts. | Saulius Zemaitaitis | 2014-03-17 | 1 | -1/+1 | |
| | |_|/ / / / |/| | | | | | ||||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |