summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
...
| * | | | allow to specify compression level for codecs which support thistrbs2015-09-123-10/+17
| |/ / /
* | | | Merge pull request #441 from koobs/patch-1Dana Powers2015-12-021-0/+1
|\ \ \ \ | | | | | | | | | | Include LICENSE in PyPI sdist
| * | | | Include LICENSE in PyPI sdistKubilay Kocak2015-07-311-0/+1
| | |/ / | |/| |
* | | | Merge pull request #439 from chrischamberlin/fix-murmurDana Powers2015-12-022-10/+35
|\ \ \ \ | | | | | | | | | | Fix translation of Java murmur2 code, fix byte encoding for Python 3.
| * | | | Fix translation of Java murmur2 code, fix byte encoding for Python 3.Chris Chamberlin2015-07-282-10/+35
| |/ / / | | | | | | | | | | | | | | | | | | | | 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-022-1/+15
|\ \ \ \ | | | | | | | | | | Reworked the if statement logic to only call stop() on not-stopped producer objects
| * | | | Fixing https://github.com/mumrah/kafka-python/issues/434toli2015-07-242-1/+15
| | | | | | | | | | | | | | | | | | | | | | | | | 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-023-5/+53
|\ \ \ \ \ | |_|_|_|/ |/| | | | Allow null payload for deletion feature
| * | | | Producer test fix for python3Viktor Shlapakov2015-06-171-1/+1
| | | | |
| * | | | Add KeyedProducer test with null payloadsViktor Shlapakov2015-06-171-0/+22
| | | | |
| * | | | Add basic keyed producer testsViktor Shlapakov2015-06-171-2/+22
| | | | |
| * | | | 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
| | |/ / | |/| |
* | | | Merge pull request #432 from ecanzonieri/lower_logging_level_metadataDana Powers2015-08-241-2/+2
|\ \ \ \ | |/ / / |/| | | Use debug logging level for metadata request
| * | | Use debug logging level for metadata requestEnrico Canzonieri2015-07-211-2/+2
|/ / /
* | | Merge pull request #412 from haosdent/seek_absolute_offsetDana Powers2015-06-202-17/+60
|\ \ \ | | | | | | | | fix #410 SimpleConsumer cannot seek to an absolute offset.
| * | | fix #410 SimpleConsumer cannot seek to an absolute offset.haosdent2015-06-202-17/+60
| | | |
* | | | Merge pull request #415 from ecanzonieri/lower_logging_levelDana Powers2015-06-192-2/+2
|\ \ \ \ | |/ / / |/| | | Lower logging level on replica not available and commit
| * | | 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
| | |
* | | Update docs to 0.9.4 as latestDana Powers2015-06-121-1/+1
| |/ |/|
* | Release 0.9.4v0.9.4Dana Powers2015-06-122-3/+3
| |
* | Update CHANGELOG for 0.9.4Dana Powers2015-06-111-0/+69
| |
* | Update contributors list -- great community!Dana Powers2015-06-111-2/+5
| |
* | Add KafkaClient.topics property to get list of known topicsDana Powers2015-06-111-0/+4
| |
* | Some minor updates to usage docsDana Powers2015-06-111-35/+40
| |
* | Fix reading version in docs/conf.pyDana Powers2015-06-111-3/+2
| |
* | Increase timeout and backoff when retrying spawn of test fixturesDana Powers2015-06-111-2/+16
| |
* | 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
| | |
* | | Merge pull request #399 from dpkp/refactor_simple_consumer_get_messagesDana Powers2015-06-101-29/+33
|\ \ \ | | | | | | | | Refactor SimpleConsumer get_messages and _fetch
| * | | 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 #402 from dpkp/kafka_0_8_2_1Dana Powers2015-06-109-12/+181
|\ \ \ \ | |/ / / |/| | | Use kafka 0.8.2.1 in integration tests
| * | | Update to 0.8.2.1 compatibility in docsDana Powers2015-06-102-4/+4
| | | |
| * | | Add kafka 0.8.2.1 to integration tests, remove 0.8.2.0Dana Powers2015-06-107-8/+177
| | | |
* | | | 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
| | | | |
* | | | | Merge pull request #404 from dpkp/consumer_more_exception_handlingDana Powers2015-06-103-19/+79
|\ \ \ \ \ | |_|/ / / |/| | | | Consumer - handle exceptions in commit() and reset_partition_offset()
| * | | | Change SimpleConsumer.reset_partition_offset to return offset / None on ↵Dana Powers2015-06-101-5/+19
| | | | | | | | | | | | | | | | | | | | failure (dont raise exception)
| * | | | (test) SimpleConsumer.reset_partition_offset should not raise exception on ↵Dana Powers2015-06-101-1/+16
| | | | | | | | | | | | | | | | | | | | failure
| * | | | Change Consumer commit() to return True/False and log error; dont raise ↵Dana Powers2015-06-101-12/+18
| | | | | | | | | | | | | | | | | | | | client exceptions
| * | | | (test) Consumer commit() should log errors and return True/False, not raise ↵Dana Powers2015-06-101-0/+24
| | | | | | | | | | | | | | | | | | | | exceptions
| * | | | Split consumer test class between Simple and MultiProcessDana Powers2015-06-101-1/+2
| | | | |
View Lorry Controller Status