| Commit message (Collapse) | Author | Age | Files | Lines | ||
|---|---|---|---|---|---|---|
| ... | ||||||
| | * | | Returned original tests, rm dirty flag, name fixes | Viktor Shlapakov | 2015-02-25 | 3 | -25/+61 | |
| | | | | ||||||
| | * | | Make KafkaConnection copies usable across threads | Alexey Borzenkov | 2015-02-25 | 1 | -0/+4 | |
| | | | | ||||||
| | * | | Trying to use threading for async batching | Viktor Shlapakov | 2015-02-25 | 1 | -3/+5 | |
| | | | | ||||||
| * | | | Merge branch 'jobevers-master' | Dana Powers | 2015-03-08 | 1 | -1/+3 | |
| |\ \ \ | | | | | | | | | | | | | PR 302: Add failed_payloads attribute to FailedPayloadsError | |||||
| | * | | | Add failed_payloads attribute to FailedPayloadsError | Job Evers | 2015-03-08 | 1 | -1/+3 | |
| | | | | | ||||||
| * | | | | Merge pull request #332 from dpkp/kafka_client_edits | Dana Powers | 2015-03-07 | 2 | -14/+11 | |
| |\ \ \ \ | | | | | | | | | | | Kafka client edits | |||||
| | * | | | | KafkaClient.get_partition_ids_for_topic now returns empty list for unknown ↵ | Dana Powers | 2015-03-02 | 1 | -1/+1 | |
| | | | | | | | | | | | | | | | | | | | | | topics | |||||
| | * | | | | Add comment about no server response case in _send_broker_aware_request | Dana Powers | 2015-03-02 | 1 | -0/+5 | |
| | | | | | | ||||||
| | * | | | | Avoid topic_partitions KeyError in KafkaClient | Dana Powers | 2015-03-02 | 1 | -1/+1 | |
| | | | | | | ||||||
| | * | | | | Remove KafkaConsumer.BYTES_CONFIGURATION_KEYS | Dana Powers | 2015-03-01 | 1 | -11/+2 | |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | - rely on KafkaClient to handle client_id string/bytes encoding - accept either string or bytes for group_id - convert group_id string to utf-8 bytes internally | |||||
| | * | | | | Accept KafkaClient client_id as string or bytes; encode string client_id as ↵ | Dana Powers | 2015-03-01 | 1 | -1/+2 | |
| | | |_|/ | |/| | | | | | | | | | | utf-8 bytes internally | |||||
| * | | | | Merge pull request #324 from chmduquesne/master | Dana Powers | 2015-03-02 | 2 | -0/+9 | |
| |\ \ \ \ | | | | | | | | | | | Properly destroying the objects that contain daemonized threads | |||||
| | * | | | | Stopping daemonized threads when references to these threads are lost | Christophe-Marie Duquesne | 2015-03-02 | 2 | -0/+9 | |
| | |/ / / | ||||||
| * | | | | Merge pull request #328 from wkiser/validate_offset | Dana Powers | 2015-03-02 | 2 | -0/+8 | |
| |\ \ \ \ | | | | | | | | | | | Fixes consumer/kafka and consumer/simple to only yield messages if the m... | |||||
| | * | | | | Fixes consumer/kafka and consumer/simple to only yield messages if the ↵ | wkiser | 2015-03-02 | 2 | -0/+8 | |
| | |/ / / | | | | | | | | | | | | | message's offset is greater than or equal to the consumer offset. | |||||
| * | | | | Merge pull request #296 from ecanzonieri/validate_consumer_offset | Dana Powers | 2015-03-02 | 2 | -4/+97 | |
| |\ \ \ \ | |/ / / |/| | | | Validate consumer offset in SimpleConsumer | |||||
| | * | | | Retry failed partitions and add integration tests | Enrico Canzonieri | 2015-01-26 | 2 | -1/+45 | |
| | | | | | ||||||
| | * | | | Merge branch 'master' of github.com:mumrah/kafka-python into ↵ | Enrico Canzonieri | 2015-01-26 | 35 | -596/+1652 | |
| | |\ \ \ | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | validate_consumer_offset Conflicts: kafka/consumer/simple.py | |||||
| | * | | | | Make SimpleConsumer auto_offset_reset more like KafkaConsumer | Enrico Canzonieri | 2015-01-26 | 1 | -4/+19 | |
| | | | | | | ||||||
| | * | | | | use a list in send_offset_request | Enrico Canzonieri | 2015-01-14 | 1 | -3/+4 | |
| | | | | | | ||||||
| | * | | | | Implement offsets reset when OffsetOutOfRangeError | Enrico Canzonieri | 2015-01-14 | 1 | -3/+35 | |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | This slightly changes the SimpleConsumer interface adding the default option use_latest_offsets. The fetch behaviour is also changed since it does not raise OffsetOutOfRangeError anymore. Resetting the offsets automatically is especially useful in MultiprocessConsumer, where an explicit seek call is not possible. | |||||
| * | | | | | Merge pull request #314 from dpkp/keyed_producer_failover | Dana Powers | 2015-02-19 | 6 | -145/+231 | |
| |\ \ \ \ \ | |_|_|_|/ |/| | | | | Handle keyed producer failover | |||||
| | * | | | | Reorganize producer integration tests; protect against non-sorted partition ↵ | Dana Powers | 2015-02-09 | 1 | -121/+160 | |
| | | | | | | | | | | | | | | | | | | | | | metadata | |||||
| | * | | | | Use a different topic for each producer integration test for isolation | Dana Powers | 2015-02-09 | 1 | -1/+0 | |
| | | | | | | ||||||
| | * | | | | Always use the initial partition list when hashing keys in KeyedProducer | Dana Powers | 2015-02-09 | 1 | -1/+1 | |
| | | | | | | ||||||
| | * | | | | make partitions arg optional in *Partitioner.partition, defaulting to ↵ | Dana Powers | 2015-02-09 | 3 | -7/+8 | |
| | | | | | | | | | | | | | | | | | | | | | self.partitions from init | |||||
| | * | | | | Add more comments to test_switch_leader regarding req_acks policy | Dana Powers | 2015-02-09 | 1 | -3/+10 | |
| | | | | | | ||||||
| | * | | | | Write a test for issue 313 - keyed producer failover | Dana Powers | 2015-02-09 | 1 | -0/+40 | |
| | | | | | | ||||||
| | * | | | | use setUp / tearDown to rebuild fixtures for each test in ↵ | Dana Powers | 2015-02-09 | 1 | -12/+12 | |
| | | | | | | | | | | | | | | | | | | | | | test_failover_integration | |||||
| * | | | | | Merge pull request #317 from sontek/update_consumer_docs | Dana Powers | 2015-02-10 | 2 | -5/+10 | |
| |\ \ \ \ \ | | | | | | | | | | | | | Updated documentation for Consumers to prefer KafkaConsumer instead | |||||
| | * | | | | | Updated documentation for Consumers to prefer KafkaConsumer instead | John Anderson | 2015-02-09 | 2 | -5/+10 | |
| | | | | | | | ||||||
| * | | | | | | Merge pull request #316 from sontek/add_docs_to_tox | Dana Powers | 2015-02-10 | 9 | -70/+230 | |
| |\ \ \ \ \ \ | | | | | | | | | | | | | | | Allow better usage of docs locally. | |||||
| | * | | | | | | Need to commit apidoc for RTD | John Anderson | 2015-02-10 | 6 | -1/+208 | |
| | | | | | | | | ||||||
| | * | | | | | | Use sphinx-apidoc to to generate API docs | John Anderson | 2015-02-10 | 5 | -66/+5 | |
| | | | | | | | | ||||||
| | * | | | | | | Allow better usage of docs locally. | John Anderson | 2015-02-09 | 3 | -4/+18 | |
| | | |/ / / / | |/| | | | | | | | | | | | | | | | | | | | | | | This will default to the rtd theme and introduces tox -e docs for generating docs locally. | |||||
| * | | | | | | Merge pull request #321 from sontek/switch_to_rst | Dana Powers | 2015-02-10 | 3 | -48/+63 | |
| |\ \ \ \ \ \ | | | | | | | | | | | | | | | Switch to rst and use in setup.py | |||||
| | * | | | | | | Added py3 to classifiers | John Anderson | 2015-02-10 | 1 | -0/+3 | |
| | | | | | | | | ||||||
| | * | | | | | | Final formatting | John Anderson | 2015-02-10 | 1 | -2/+4 | |
| | | | | | | | | ||||||
| | * | | | | | | More formatting cleanup | John Anderson | 2015-02-10 | 1 | -2/+2 | |
| | | | | | | | | ||||||
| | * | | | | | | Cleaned up some formatting | John Anderson | 2015-02-10 | 1 | -7/+7 | |
| | | | | | | | | ||||||
| | * | | | | | | Move to .rst and use it in setup.py for long description | John Anderson | 2015-02-10 | 2 | -14/+24 | |
| |/ / / / / / | ||||||
| * | | | | | | Merge pull request #320 from sontek/dont_link_to_mobile | David Arthur | 2015-02-10 | 1 | -1/+1 | |
| |\ \ \ \ \ \ | |/ / / / / |/| | | | | | This links to the main page not the mobile site | |||||
| | * | | | | | This links to the main page not the mobile site | John Anderson | 2015-02-10 | 1 | -1/+1 | |
| |/ / / / / | ||||||
| * | | | | | Merge pull request #315 from dpkp/sorted_partition_ids | Mark Roberts | 2015-02-09 | 1 | -1/+1 | |
| |\ \ \ \ \ | |/ / / / |/| | | | | Always return sorted partition ids in client.get_partition_ids_for_topic() | |||||
| | * | | | | Always return sorted partition ids in KafkaClient.get_partition_ids_for_topic() | Dana Powers | 2015-02-09 | 1 | -1/+1 | |
| |/ / / / | ||||||
| * | | | | Fixup index.rst | Dana Powers | 2015-02-05 | 1 | -0/+1 | |
| | | | | | ||||||
| * | | | | Update docs/index.rst for sphinx/RTD | Dana Powers | 2015-02-05 | 1 | -7/+8 | |
| | | | | | ||||||
| * | | | | 2014 -> 2015 | David Arthur | 2015-02-03 | 3 | -3/+3 | |
| | | | | | ||||||
| * | | | | Adding ReadTheDocs badge | David Arthur | 2015-02-03 | 1 | -1/+2 | |
| | | | | | | | | | | | | | Because you can never have enough badges | |||||
| * | | | | Removing traces of queue.py | David Arthur | 2015-02-03 | 2 | -4/+1 | |
| | | | | | ||||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |