summaryrefslogtreecommitdiff
path: root/kafka
Commit message (Collapse)AuthorAgeFilesLines
...
| * | | | Fix translation of Java murmur2 code, fix byte encoding for Python 3.Chris Chamberlin2015-07-281-10/+12
| | |/ / | |/| | | | | | | | | | | | | | | | | | 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-logicDana Powers2015-12-021-1/+1
|\ \ \ \ | | | | | | | | | | Reworked the if statement logic to only call stop() on not-stopped producer objects
| * | | | Fixing https://github.com/mumrah/kafka-python/issues/434toli2015-07-241-1/+1
| | | | | | | | | | | | | | | | | | | | | | | | | Reworked the if statement logic to only call stop() on not-stopped objects. added tests
* | | | | Merge pull request #418 from scrapinghub/mp_partition_infoDana Powers2015-12-023-8/+10
|\ \ \ \ \ | | | | | | | | | | | | allow to retrieve partition info in mp consumer
| * | | | | allow to retrieve partition info in mp consumerMartin Olveyra2015-06-293-8/+10
| | |/ / / | |/| | |
* | | | | Merge pull request #409 from scrapinghub/feature-allow-null-payloadDana Powers2015-12-021-3/+9
|\ \ \ \ \ | |_|_|_|/ |/| | | | Allow null payload for deletion feature
| * | | | Exclude (null,null) pair for producerViktor Shlapakov2015-06-171-3/+9
| | | | |
| * | | | Allow null payload for deletion featureViktor Shlapakov2015-06-161-1/+1
| | | | |
* | | | | Merge pull request #436 from mutability/async-catch-unavailable-errorDana Powers2015-10-071-6/+11
|\ \ \ \ \ | |_|_|_|/ |/| | | | Catch KafkaUnavailableError in _send_broker_aware_request
| * | | | Init responses before we use it.Oliver Jowett2015-07-241-1/+1
| | | | |
| * | | | Errors -> Error typoOliver Jowett2015-07-201-1/+1
| | | | |
| * | | | Treat KafkaUnavailableError like other errors.Oliver Jowett2015-07-191-5/+10
| | |/ / | |/| |
* | | | Use debug logging level for metadata requestEnrico Canzonieri2015-07-211-2/+2
|/ / /
* | | Merge pull request #412 from haosdent/seek_absolute_offsetDana Powers2015-06-201-17/+46
|\ \ \ | | | | | | | | fix #410 SimpleConsumer cannot seek to an absolute offset.
| * | | fix #410 SimpleConsumer cannot seek to an absolute offset.haosdent2015-06-201-17/+46
| | | |
* | | | Lower logging level on replica not available and commitEnrico Canzonieri2015-06-192-2/+2
|/ / /
* | | Set development version until next releaseDana Powers2015-06-121-1/+1
| |/ |/|
* | Release 0.9.4v0.9.4Dana Powers2015-06-121-1/+1
| |
* | Add KafkaClient.topics property to get list of known topicsDana Powers2015-06-111-0/+4
| |
* | Merge pull request #378 from dpkp/murmur2_hashed_partitionerDana Powers2015-06-102-3/+98
|\ \ | | | | | | Use MurmurHash2 for key partition hashing
| * | Use MurmurHash2 for key partition hashingDana Powers2015-06-102-3/+98
| | |
* | | Refactor SimpleConsumer get_messages and _fetchDana Powers2015-06-101-29/+33
| | | | | | | | | | | | | | | - attempt to make these easier to read - add marginal retry logic to internal _fetch loop
* | | Merge pull request #405 from dpkp/log_error_typeDana Powers2015-06-102-7/+11
|\ \ \ | | | | | | | | Log response error types in consumer and producer logs
| * | | Add error type to SimpleConsumer error loggingDana Powers2015-06-101-5/+8
| | | |
| * | | Log response error type in async producerDana Powers2015-06-101-2/+3
| |/ /
* | | Change SimpleConsumer.reset_partition_offset to return offset / None on ↵Dana Powers2015-06-101-5/+19
| | | | | | | | | | | | failure (dont raise exception)
* | | Change Consumer commit() to return True/False and log error; dont raise ↵Dana Powers2015-06-101-12/+18
|/ / | | | | | | client exceptions
* | Fix KafkaClient request / response orderingDana Powers2015-06-101-10/+20
|/
* Add send/receive debug logging to async producerDana Powers2015-06-091-8/+11
|
* KafkaClient log new broker and topic metadata received as INFODana Powers2015-06-091-2/+2
|
* KafkaClient: log responses by requestId for debuggingDana Powers2015-06-091-1/+4
|
* KafkaClient: log requestId on ConnectionError instead of hexdump of request ↵Dana Powers2015-06-091-6/+5
| | | | contents
* Merge pull request #398 from dpkp/kafka_consumer_failed_payloadsDana Powers2015-06-091-37/+61
|\ | | | | Kafka consumer failed payloads
| * KafkaConsumer style nitsDana Powers2015-06-081-26/+48
| |
| * Update KafkaConsumer to handle request-specific FailedPayloadsErrorsDana Powers2015-06-081-11/+13
| |
* | Support sync_fail_on_error kwarg in ProducerDana Powers2015-06-091-2/+12
| |
* | Use a list, not request_tries.keys(), to track requests / responses in async ↵Dana Powers2015-06-091-2/+4
|/ | | | producer
* Fixup for loop vars in kafka/protocol.pyDana Powers2015-06-081-14/+14
|
* Improve kafka client debug request/response loggingDana Powers2015-06-081-5/+5
|
* Prefer single quotes for stringsDana Powers2015-06-081-14/+12
|
* Add a few extra docstring comments about thread-safe clients/connectionsDana Powers2015-06-083-5/+12
|
* Dont maintain all producer args / kwargs in subclass __init__ and docstrings ↵Dana Powers2015-06-082-91/+24
| | | | -- just refer to super class (Producer)
* Cleanup imports in kafka/client and kafka/consumerDana Powers2015-06-083-23/+21
|
* Merge pull request #389 from dpkp/task_done_key_errorDana Powers2015-06-081-2/+10
|\ | | | | KafkaConsumer.task_done: warn and skip unrecognized topic-partitions
| * KafkaConsumer.task_done - warn and skip messages from unrecognized ↵Dana Powers2015-06-061-2/+10
| | | | | | | | topic-partitions
* | SimpleConsumer should refresh metadata and retry on leadership changes; only ↵Dana Powers2015-06-081-1/+4
| | | | | | | | raise on UnknownTopicOrPartition
* | Merge pull request #380 from dpkp/multiprocess_consumer_partitionsDana Powers2015-06-081-3/+7
|\ \ | | | | | | Support optional partitions kwarg in MultiProcessConsumer
| * | Support optional partitions kwarg in MultiProcessConsumerDana Powers2015-05-171-3/+7
| | |
* | | Merge pull request #379 from dpkp/deprecate_keyed_producer_sendDana Powers2015-06-081-5/+6
|\ \ \ | | | | | | | | Deprecate KeyedProducer.send in favor of send_messages
| * | | Deprecate KeyedProducer.send in favor of send_messages -- keep interface ↵Dana Powers2015-05-171-5/+6
| | | | | | | | | | | | | | | | consistent
View Lorry Controller Status