summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* Update LICENSEv0.9.3David Arthur2015-02-031-1/+1
|
* Bump VERSIONDana Powers2015-02-031-1/+1
|
* Merge pull request #310 from dpkp/kafka_python_0_9_3Dana Powers2015-02-034-12/+43
|\ | | | | kafka-python 0.9.3
| * Update README and CHANGES for 0.9.3 releaseDana Powers2015-02-032-7/+31
| |
| * Add 0.8.2.0 to integration tests (and use recommended scala 2.10 by default)Dana Powers2015-02-032-5/+12
|/
* Merge pull request #307 from sontek/enable_coverallsDana Powers2015-02-031-1/+4
|\ | | | | This enables coveralls with travis
| * This enables coveralls with travisJohn Anderson2015-01-241-1/+4
| |
* | Merge pull request #312 from dpkp/reentrant_timer_py26Dana Powers2015-02-031-1/+5
|\ \ | | | | | | Fix python2.6 threading.Event bug in ReentrantTimer
| * | Fix python2.6 threading.Event bug in ReentrantTimerDana Powers2015-02-031-1/+5
|/ /
* | Merge pull request #306 from sontek/catch_topic_not_bytesMark Roberts2015-02-022-1/+22
|\ \ | | | | | | Alert if the topic is not sent as bytes
| * | Just encode to bytes if it isn't bytes.John Anderson2015-01-242-8/+14
| | |
| * | Alert if the topic is not sent as bytesJohn Anderson2015-01-232-0/+15
| |/
* | Merge pull request #309 from zhaopengzp/masterMark Roberts2015-02-021-0/+1
|\ \ | |/ |/| fix circle reference
| * fix circle referencezhaopengzp2015-02-021-0/+1
|/
* Merge pull request #282 from wedaly/sphinx-api-docsDana Powers2015-01-2325-542/+1436
|\ | | | | Add Sphinx API docs
| * Add Sphinx API docsWill Daly2015-01-1525-542/+1436
| |
* | Merge pull request #295 from dpkp/kafka_0_8_2Mark Roberts2015-01-157-7/+175
|\ \ | | | | | | Kafka 0.8.2.0 updates
| * | Catch ReplicaNotAvailableError in MetadataResponse -- per kafka-devs, this ↵Dana Powers2015-01-141-1/+6
| | | | | | | | | | | | error can and should be ignored
| * | Move 0.8.2-beta resources to 0.8.2.0Dana Powers2015-01-143-0/+0
| | |
| * | Add 0.8.2.0 to some kafka_version testsDana Powers2015-01-142-3/+3
| | |
| * | Change ZookeeperFixture wait_for regex to support newer zk version used with ↵Dana Powers2015-01-141-1/+1
| | | | | | | | | | | | 0.8.2.0
| * | Fix KafkaFixture child stdout / stderr captureDana Powers2015-01-141-2/+2
| | |
| * | Just copied over the 0.8.1.1 conf filesDana Powers2015-01-143-0/+163
|/ /
* | Merge pull request #289 from alexcb/broker-error-class-refactoringDana Powers2015-01-122-27/+14
|\ \ | | | | | | Use reflection to avoid multiple errno definitions
| * | Use reflection to avoid multiple errno definitionsAlex Couture-Beil2015-01-102-27/+14
| | |
* | | Merge pull request #286 from Dinoshauer/expose-KafkaConsumer-in-allDana Powers2015-01-121-1/+1
|\ \ \ | | | | | | | | KafkaConsumer should be in __all__.
| * | | KafkaConsumer should be in __all__.Kasper Jacobsen2015-01-091-1/+1
| | |/ | |/|
* | | Merge pull request #288 from alexcb/masterDana Powers2015-01-122-16/+22
|\ \ \ | |/ / |/| | Randomize start by default for SimpleProducer
| * | Updated unittests to explicitly set random_start valueAlex Couture-Beil2015-01-091-15/+21
| | |
| * | Randomize start by default for SimpleProducerAlex Couture-Beil2015-01-091-1/+1
|/ / | | | | | | | | | | | | | | random_start=False is dangerous. Any client that initializes a SimpleProducer and performs only a single publish batch will always go to partition 0. A common use-case for this is command line utilities, or web-servers which are unable to cache the SimpleProducer instance between calls.
* | Merge pull request #281 from meandthewallaby/compressed-keyMark Roberts2015-01-021-2/+2
|\ \ | |/ | | Added keys to compressed messages (both gzip and snappy).
| * Added keys to compressed messages (both gzip and snappy).Eric Hewitt2015-01-021-2/+2
|/
* Merge pull request #234 from dpkp/high_level_consumerMark Roberts2014-12-1614-68/+941
|\ | | | | A simpler kafka consumer
| * Add some jitter to refresh_leader_backoff_ms, per wizzat reviewDana Powers2014-12-151-1/+7
| |
| * Simplify BYTES_CONFIGURATION_KEYS logic, per wizzat reviewDana Powers2014-12-151-2/+1
| |
| * Fixup call to self._client.get_partition_ids_for_topic -- use encoded topic ↵Dana Powers2014-12-151-1/+1
| | | | | | | | bytes
| * Use kafka.util.kafka_bytestring to encode utf-8 when necessaryDana Powers2014-12-152-15/+18
| |
| * OffsetCommit metadata must be bytesDana Powers2014-12-151-1/+1
| |
| * Add private methods _does_auto_commit_ms and _does_auto_commit_messagesDana Powers2014-12-151-7/+22
| |
| * Make TIMEOUT_MS configurable in test_kafka_consumer__blockingDana Powers2014-12-151-4/+5
| |
| * Merge conflict w/ assertEqual (assertEquals deprecated)Dana Powers2014-12-157-50/+52
| |
| * Fix task_done checks when no previous commit exists; add testDana Powers2014-12-152-6/+48
| |
| * Force absolue_imports in kafka/consumer/kafka.pyDana Powers2014-12-151-0/+2
| |
| * Move KafkaConsumer to kafka.consumer.kafka module; make available for import ↵Dana Powers2014-12-155-8/+7
| | | | | | | | from kafka at top-level
| * Use six for py3 support in KafkaConsumerDana Powers2014-12-152-16/+42
| | | | | | | | Log connection failures w/ traceback in kafka/client.py
| * Update docstrings w/ current interface / config defaultsDana Powers2014-12-151-16/+21
| |
| * Raise KafkaConfigurationError during fetch_messages if not topics/partitions ↵Dana Powers2014-12-151-1/+7
| | | | | | | | configured
| * Move auto-commit checks to task_done; add support for ↵Dana Powers2014-12-151-11/+27
| | | | | | | | auto_commit_interval_messages
| * Add private methods to manage internal _msg_iterDana Powers2014-12-151-10/+20
| |
| * Reorder methods, add docstrings to public methds, section comments for ↵Dana Powers2014-12-151-207/+255
| | | | | | | | private methods
View Lorry Controller Status