| Commit message (Collapse) | Author | Age | Files | Lines | ||
|---|---|---|---|---|---|---|
| ... | ||||||
| | * | | Fix misnamed node to nodeId in test | tpalino | 2015-07-02 | 1 | -1/+1 | |
| | | | | ||||||
| | * | | Add missing import for ConsumerMetadataResponse | tpalino | 2015-07-01 | 1 | -1/+1 | |
| | | | | ||||||
| | * | | Support consumer metadata requests | tpalino | 2015-07-01 | 4 | -6/+225 | |
| | |/ | | | | | | | | | | | Support added for ConsumerMetadataRequest and ConsumerMetadataResponse Added consumer-aware request routine for supporting the consumer coordinator Added separate client method for fetching Kafka-committed offsets from the coordinator | |||||
| * | | Fix python3 / python2 comments re queue/Queue | Dana Powers | 2015-12-02 | 2 | -10/+10 | |
| | | | ||||||
| * | | Add Murmur2Partitioner to kafka __all__ imports - fix issue 471 | Dana Powers | 2015-12-02 | 1 | -1/+1 | |
| | | | ||||||
| * | | Merge pull request #473 from ecanzonieri/use_unblocking_io_for_aware_requests | Dana Powers | 2015-12-02 | 3 | -18/+52 | |
| |\ \ | | | | | | | Use unblocking io for broker aware requests | |||||
| | * | | Add tests. Bug fix. Rename socket_conn dict. | Enrico Canzonieri | 2015-11-10 | 2 | -7/+24 | |
| | | | | ||||||
| | * | | Unblocking broker aware request | Enrico Canzonieri | 2015-11-10 | 2 | -18/+35 | |
| | | | | ||||||
| * | | | Merge pull request #467 from bschopman/master | Dana Powers | 2015-12-02 | 2 | -2/+9 | |
| |\ \ \ | | | | | | | | | Prevents crashing communication thread of async producer | |||||
| | * | | | Prevents crashing communication thread of async producer | Balthasar Schopman | 2015-10-22 | 2 | -2/+9 | |
| | |/ / | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | If an uncaught exception occurs in _send_messages() the thread sending data to Kafka (asynchronously) will crash and the queue will never be emptied. To reproduce: 1) Run an Async producer. 2) Kill the Kafka server. 3) Restart the Kafka server. The communication thread dies shortly after step 2. After step 3 the communication does not resume without this commit. The changes in both files prevent an Exception from being thrown through to do main communication process, which could cause the crash. | |||||
| * | | | Merge pull request #457 from saaros/block-for-number-of-messages | Dana Powers | 2015-12-02 | 3 | -11/+36 | |
| |\ \ \ | | | | | | | | | Consumers get_messages: allow blocking until some messages are received | |||||
| | * | | | Consumers get_messages: allow blocking until some messages are received | Oskari Saarenmaa | 2015-09-18 | 3 | -11/+36 | |
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Modified MultiProcessConsumer's and SimpleConsumer's `block` argument to allow integer value which defines the number of messages to block for. This allows callers to ask for a high number of messages and block only until some of them are received. Otherwise callers would have to request messages one by one or block for some time. | |||||
| * | | | | Merge pull request #446 from zackdever/consumer-class-configs | Dana Powers | 2015-12-02 | 1 | -2/+3 | |
| |\ \ \ \ | | | | | | | | | | | Set default config on consumer class to support subclass config changes. | |||||
| | * | | | | set default config on consumer class to support subclass config changes. | Zack Dever | 2015-08-13 | 1 | -2/+3 | |
| | | |_|/ | |/| | | ||||||
| * | | | | Merge pull request #456 from barricadeio/mp-retry | Dana Powers | 2015-12-02 | 3 | -46/+63 | |
| |\ \ \ \ | | | | | | | | | | | Support retry semantics in MultiProcessConsumer | |||||
| | * | | | | Support retry semantics in MultiProcessConsumer | Ross Duggan | 2015-09-14 | 3 | -46/+63 | |
| | | |/ / | |/| | | ||||||
| * | | | | Merge pull request #454 from trbs/gzip_compressionlevel | Dana Powers | 2015-12-02 | 3 | -10/+17 | |
| |\ \ \ \ | | | | | | | | | | | allow to specify compression level for codecs which support this | |||||
| | * | | | | allow to specify compression level for codecs which support this | trbs | 2015-09-12 | 3 | -10/+17 | |
| | |/ / / | ||||||
| * | | | | Merge pull request #441 from koobs/patch-1 | Dana Powers | 2015-12-02 | 1 | -0/+1 | |
| |\ \ \ \ | | | | | | | | | | | Include LICENSE in PyPI sdist | |||||
| | * | | | | Include LICENSE in PyPI sdist | Kubilay Kocak | 2015-07-31 | 1 | -0/+1 | |
| | | |/ / | |/| | | ||||||
| * | | | | Merge pull request #439 from chrischamberlin/fix-murmur | Dana Powers | 2015-12-02 | 2 | -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 Chamberlin | 2015-07-28 | 2 | -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-logic | Dana Powers | 2015-12-02 | 2 | -1/+15 | |
| |\ \ \ \ | | | | | | | | | | | Reworked the if statement logic to only call stop() on not-stopped producer objects | |||||
| | * | | | | Fixing https://github.com/mumrah/kafka-python/issues/434 | toli | 2015-07-24 | 2 | -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_info | Dana Powers | 2015-12-02 | 3 | -8/+10 | |
| |\ \ \ \ \ | | | | | | | | | | | | | allow to retrieve partition info in mp consumer | |||||
| | * | | | | | allow to retrieve partition info in mp consumer | Martin Olveyra | 2015-06-29 | 3 | -8/+10 | |
| | | |/ / / | |/| | | | ||||||
| * | | | | | Merge pull request #409 from scrapinghub/feature-allow-null-payload | Dana Powers | 2015-12-02 | 3 | -5/+53 | |
| |\ \ \ \ \ | |_|_|_|/ |/| | | | | Allow null payload for deletion feature | |||||
| | * | | | | Producer test fix for python3 | Viktor Shlapakov | 2015-06-17 | 1 | -1/+1 | |
| | | | | | | ||||||
| | * | | | | Add KeyedProducer test with null payloads | Viktor Shlapakov | 2015-06-17 | 1 | -0/+22 | |
| | | | | | | ||||||
| | * | | | | Add basic keyed producer tests | Viktor Shlapakov | 2015-06-17 | 1 | -2/+22 | |
| | | | | | | ||||||
| | * | | | | Exclude (null,null) pair for producer | Viktor Shlapakov | 2015-06-17 | 1 | -3/+9 | |
| | | | | | | ||||||
| | * | | | | Allow null payload for deletion feature | Viktor Shlapakov | 2015-06-16 | 1 | -1/+1 | |
| | | | | | | ||||||
| * | | | | | Merge pull request #436 from mutability/async-catch-unavailable-error | Dana Powers | 2015-10-07 | 1 | -6/+11 | |
| |\ \ \ \ \ | |_|_|_|/ |/| | | | | Catch KafkaUnavailableError in _send_broker_aware_request | |||||
| | * | | | | Init responses before we use it. | Oliver Jowett | 2015-07-24 | 1 | -1/+1 | |
| | | | | | | ||||||
| | * | | | | Errors -> Error typo | Oliver Jowett | 2015-07-20 | 1 | -1/+1 | |
| | | | | | | ||||||
| | * | | | | Treat KafkaUnavailableError like other errors. | Oliver Jowett | 2015-07-19 | 1 | -5/+10 | |
| | | |/ / | |/| | | ||||||
| * | | | | Merge pull request #432 from ecanzonieri/lower_logging_level_metadata | Dana Powers | 2015-08-24 | 1 | -2/+2 | |
| |\ \ \ \ | |/ / / |/| | | | Use debug logging level for metadata request | |||||
| | * | | | Use debug logging level for metadata request | Enrico Canzonieri | 2015-07-21 | 1 | -2/+2 | |
| |/ / / | ||||||
| * | | | Merge pull request #412 from haosdent/seek_absolute_offset | Dana Powers | 2015-06-20 | 2 | -17/+60 | |
| |\ \ \ | | | | | | | | | fix #410 SimpleConsumer cannot seek to an absolute offset. | |||||
| | * | | | fix #410 SimpleConsumer cannot seek to an absolute offset. | haosdent | 2015-06-20 | 2 | -17/+60 | |
| | | | | | ||||||
| * | | | | Merge pull request #415 from ecanzonieri/lower_logging_level | Dana Powers | 2015-06-19 | 2 | -2/+2 | |
| |\ \ \ \ | |/ / / |/| | | | Lower logging level on replica not available and commit | |||||
| | * | | | Lower logging level on replica not available and commit | Enrico Canzonieri | 2015-06-19 | 2 | -2/+2 | |
| |/ / / | ||||||
| * | | | Set development version until next release | Dana Powers | 2015-06-12 | 1 | -1/+1 | |
| | | | | ||||||
| * | | | Update docs to 0.9.4 as latest | Dana Powers | 2015-06-12 | 1 | -1/+1 | |
| | |/ |/| | ||||||
| * | | Release 0.9.4v0.9.4 | Dana Powers | 2015-06-12 | 2 | -3/+3 | |
| | | | ||||||
| * | | Update CHANGELOG for 0.9.4 | Dana Powers | 2015-06-11 | 1 | -0/+69 | |
| | | | ||||||
| * | | Update contributors list -- great community! | Dana Powers | 2015-06-11 | 1 | -2/+5 | |
| | | | ||||||
| * | | Add KafkaClient.topics property to get list of known topics | Dana Powers | 2015-06-11 | 1 | -0/+4 | |
| | | | ||||||
| * | | Some minor updates to usage docs | Dana Powers | 2015-06-11 | 1 | -35/+40 | |
| | | | ||||||
| * | | Fix reading version in docs/conf.py | Dana Powers | 2015-06-11 | 1 | -3/+2 | |
| | | | ||||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |