summaryrefslogtreecommitdiff
path: root/kafka
Commit message (Collapse)AuthorAgeFilesLines
...
* Expose selector type as config option (#764)Dana Powers2016-07-163-3/+15
|
* Protect writes to wakeup socket with threading lock (#763 / #709)Dana Powers2016-07-161-2/+6
|
* Merge pull request #762 from dpkp/metadata_v1Dana Powers2016-07-166-24/+117
|\ | | | | Use Metadata Request/Response v1 with 0.10+ brokers
| * Use MetadataRequest v1 for 0.10+ api_versionmetadata_v1Dana Powers2016-07-162-9/+51
| |
| * Add rack to BrokerMetadata - it is always None when using MetadataRequest v0Dana Powers2016-07-163-12/+15
| |
| * Add protocol structs for Metadata v1Dana Powers2016-07-161-4/+36
| |
| * Add protocol support for null ArraysDana Powers2016-07-161-0/+6
| |
| * Add Boolean protocol typeDana Powers2016-07-161-0/+10
| |
* | Update kafka configuration links -> 0.10.0.0 docsDana Powers2016-07-162-2/+2
| |
* | Merge pull request #754 from dpkp/benchmarksDana Powers2016-07-167-22/+292
|\ \ | | | | | | Producer metrics + consumer/producer benchmark scripts
| * | Update Sensor time_ms docs; only calculate if neededDana Powers2016-07-161-3/+3
| | |
| * | First stab at public metrics() interface for KafkaConsumer / KafkaProducerDana Powers2016-07-162-2/+31
| | |
| * | Add comment re fetcher stats on compressed topicsDana Powers2016-07-161-0/+2
| | |
| * | Fixup metrics_sample_window_ms docstring in consumerDana Powers2016-07-161-2/+2
| | |
| * | KAFKA-3785: Fetcher spending unnecessary time during metrics recordingDana Powers2016-07-161-2/+4
| | |
| * | Add initial producer-sender metricsDana Powers2016-07-164-13/+250
| |/
* | #761 Follow-up: use api_version tuples in BrokerConnection.check_versionDana Powers2016-07-161-11/+10
|/
* Add api_version config to KafkaClient, deprecate str in favor of tuples (#761)Dana Powers2016-07-164-32/+81
|
* Fix KafkaConsumer autocommit for 0.8 brokers (#756 / #706)Dana Powers2016-07-162-20/+25
| | | | * Dont wait for group join to enable AutoCommitTask if broker version < 0.9 * For zookeeper offset storage, set a "coordinator" with least_loaded_node
* Cleanup error logging (#760 / #759)Dana Powers2016-07-152-2/+12
| | | | | | - add error type to all KafkaErrors - add args to BrokerResponseError - drop description from BrokerResponseError - fix bug logging errbacks as callbacks
* Bump version for developmentDana Powers2016-07-151-1/+1
|
* Patch Release 1.2.51.2.5Dana Powers2016-07-151-1/+1
|
* Add skip_double_compressed_messages option to KafkaConsumerunrecurse_unpack_message_setDana Powers2016-07-142-0/+20
|
* Log warning if message set appears double-compressed in KafkaConsumerDana Powers2016-07-141-0/+8
|
* Drop recursion in _unpack_message_setDana Powers2016-07-141-17/+36
|
* Fix bug causing KafkaProducer to double-compress message batches on retrydouble_compressionDana Powers2016-07-141-16/+23
|
* Bump version for developmentDana Powers2016-07-101-1/+1
|
* Patch Release 1.2.41.2.4Dana Powers2016-07-081-1/+1
|
* Update consumer_timeout_ms docstring per #749Dana Powers2016-07-081-3/+3
|
* Use explicit subscription state flag to handle seek() during message iterationcompacted_offsetsDana Powers2016-07-082-1/+17
|
* Fix consumer iteration on compacted topicsDana Powers2016-07-081-1/+1
|
* Add ssl_password to default_config dicts. Send ssl_password when loading ↵Ashley McKemie2016-07-083-1/+5
| | | | cert chains (#750)
* Avoid AttributeErrors in _unregister_cleanup (#747)Dana Powers2016-07-051-1/+1
|
* Patch Release 1.2.3Dana Powers2016-07-021-1/+1
|
* Randomize order of topics/partitions processed by fetcher to improve balance ↵Dana Powers2016-06-291-0/+4
| | | | (#732)
* allow client.check_version timeout to be set in Producer and Consumer ↵eastlondoner2016-06-292-2/+10
| | | | | constructors (#647) * allow client.check_version timeout to be set in Producer and Consumer constructors
* Wakeup socket optimizations (#740)Dana Powers2016-06-262-2/+7
|
* assert will be disabled by "python -O" (#736)tyronecai2016-06-231-4/+4
|
* Bump version for developmentDana Powers2016-06-211-1/+1
|
* Patch Release 1.2.21.2.2Dana Powers2016-06-211-1/+1
|
* Clarify timeout unit (#734)ms7s2016-06-211-1/+8
|
* Avoid busy poll during metadata refresh failure with retry_backoff_ms (#733)Dana Powers2016-06-202-30/+47
|
* check_version should scan nodes until version found or timeout (#731)Dana Powers2016-06-192-17/+46
| | | | | * Mute all connection logging during conn.check_version * Always process pending MetadataRequest in conn.check_version * KakfaClient.check_version: Scan all brokers until a version is identified or timeout
* Update KafkaClient.least_loaded_node (#730)Dana Powers2016-06-181-23/+17
| | | | | | - Main node loop should check all known brokers, not just conn objects, which is consistent with the official java client. - This fixes a bug which could cause least_loaded_node to always return the same unavailable node
* Use weakref when registering a producer.close atexit to fix normal gc (#728)Dana Powers2016-06-182-3/+47
| | | | * Use weakref when registering a producer.close atexit to fix normal gc * Test that del(producer) terminates async thread
* Close selector when closing the client connection to fix fd leak. (#729)Michael Smith2016-06-171-0/+1
|
* tweak spelling mistake (#719)steve89182016-06-171-1/+1
|
* Bump version for developmentDana Powers2016-06-011-1/+1
|
* Patch Release 1.2.11.2.1Dana Powers2016-06-011-1/+1
|
* Fix regression in MessageSet decoding wrt PartialMessages (#716)Dana Powers2016-06-011-3/+6
|
View Lorry Controller Status