| Commit message (Collapse) | Author | Age | Files | Lines | ||
|---|---|---|---|---|---|---|
| ... | ||||||
| * | | | Merge pull request #329 from vshlapakov/feature-batch-msg-keys | Dana Powers | 2015-03-29 | 2 | -5/+5 | |
| |\ \ \ | |_|/ |/| | | Correct message keys for async batching mode | |||||
| | * | | Correct message keys for async batching mode | Viktor Shlapakov | 2015-02-25 | 2 | -5/+5 | |
| | | | | ||||||
| * | | | Merge pull request #335 from scrapinghub/fix-mp-consumer-distribution | Dana Powers | 2015-03-12 | 1 | -10/+12 | |
| |\ \ \ | |_|/ |/| | | Wrong partitions distribution logic for MP Consumer | |||||
| | * | | Used thread-safe dict.copy().keys() for MP consumer partitions | Viktor Shlapakov | 2015-03-12 | 1 | -1/+4 | |
| | | | | ||||||
| | * | | Cleaned code for MP consumer chunking | Viktor Shlapakov | 2015-03-11 | 1 | -10/+9 | |
| | | | | ||||||
| | * | | Fixing distribution for MP Consumer | Viktor Shlapakov | 2015-03-03 | 1 | -1/+1 | |
| | |/ | ||||||
| * | | Merge branch 'vshlapakov-feature-async-threading' | Dana Powers | 2015-03-08 | 2 | -26/+29 | |
| |\ \ | | | | | | | | | | | | | | | | | | | PR 330: Threading for async batching Conflicts: kafka/producer/base.py | |||||
| | * | | Async producer stop() fix | Viktor Shlapakov | 2015-02-26 | 1 | -2/+2 | |
| | | | | ||||||
| | * | | Using threading.Event to stop async producer thread | Viktor Shlapakov | 2015-02-26 | 1 | -5/+10 | |
| | | | | ||||||
| | * | | Returned original tests, rm dirty flag, name fixes | Viktor Shlapakov | 2015-02-25 | 2 | -25/+17 | |
| | | | | ||||||
| | * | | 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 | 1 | -3/+54 | |
| |\ \ \ \ | |/ / / |/| | | | Validate consumer offset in SimpleConsumer | |||||
| | * | | | Retry failed partitions and add integration tests | Enrico Canzonieri | 2015-01-26 | 1 | -0/+2 | |
| | | | | | ||||||
| | * | | | Merge branch 'master' of github.com:mumrah/kafka-python into ↵ | Enrico Canzonieri | 2015-01-26 | 16 | -342/+381 | |
| | |\ \ \ | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | 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 | 4 | -8/+9 | |
| |\ \ \ \ \ | |_|_|_|/ |/| | | | | Handle keyed producer failover | |||||
| | * | | | | 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 | |||||
| * | | | | | Merge pull request #317 from sontek/update_consumer_docs | Dana Powers | 2015-02-10 | 1 | -2/+5 | |
| |\ \ \ \ \ | |/ / / / |/| | | | | Updated documentation for Consumers to prefer KafkaConsumer instead | |||||
| | * | | | | Updated documentation for Consumers to prefer KafkaConsumer instead | John Anderson | 2015-02-09 | 1 | -2/+5 | |
| | | | | | | ||||||
| * | | | | | Always return sorted partition ids in KafkaClient.get_partition_ids_for_topic() | Dana Powers | 2015-02-09 | 1 | -1/+1 | |
| |/ / / / | ||||||
| * | | | | 2014 -> 2015 | David Arthur | 2015-02-03 | 1 | -1/+1 | |
| | | | | | ||||||
| * | | | | Removing queue.py | David Arthur | 2015-02-03 | 1 | -215/+0 | |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | It's just collecting dust and throwing off the coverage report. I pushed a branch queue-fixup in case someone wants to take a stab at refactoring it. | |||||
| * | | | | Fix python2.6 threading.Event bug in ReentrantTimer | Dana Powers | 2015-02-03 | 1 | -1/+5 | |
| | | | | | ||||||
| * | | | | Merge pull request #306 from sontek/catch_topic_not_bytes | Mark Roberts | 2015-02-02 | 1 | -1/+7 | |
| |\ \ \ \ | | | | | | | | | | | Alert if the topic is not sent as bytes | |||||
| | * | | | | Just encode to bytes if it isn't bytes. | John Anderson | 2015-01-24 | 1 | -2/+4 | |
| | | | | | | ||||||
| | * | | | | Alert if the topic is not sent as bytes | John Anderson | 2015-01-23 | 1 | -0/+4 | |
| | | |/ / | |/| | | ||||||
| * | | | | fix circle reference | zhaopengzp | 2015-02-02 | 1 | -0/+1 | |
| |/ / / | ||||||
| * | | | Merge pull request #282 from wedaly/sphinx-api-docs | Dana Powers | 2015-01-23 | 14 | -312/+357 | |
| |\ \ \ | |_|/ |/| | | Add Sphinx API docs | |||||
| | * | | Add Sphinx API docs | Will Daly | 2015-01-15 | 14 | -312/+357 | |
| | |/ | ||||||
| * | | Catch ReplicaNotAvailableError in MetadataResponse -- per kafka-devs, this ↵ | Dana Powers | 2015-01-14 | 1 | -1/+6 | |
| | | | | | | | | | error can and should be ignored | |||||
| * | | Merge pull request #289 from alexcb/broker-error-class-refactoring | Dana Powers | 2015-01-12 | 1 | -24/+12 | |
| |\ \ | | | | | | | Use reflection to avoid multiple errno definitions | |||||
| | * | | Use reflection to avoid multiple errno definitions | Alex Couture-Beil | 2015-01-10 | 1 | -24/+12 | |
| | |/ | ||||||
| * | | Merge pull request #286 from Dinoshauer/expose-KafkaConsumer-in-all | Dana Powers | 2015-01-12 | 1 | -1/+1 | |
| |\ \ | | | | | | | KafkaConsumer should be in __all__. | |||||
| | * | | KafkaConsumer should be in __all__. | Kasper Jacobsen | 2015-01-09 | 1 | -1/+1 | |
| | |/ | ||||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |