summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* Add KafkaClient metricsmore_metricsDana Powers2016-07-172-2/+53
|
* Record produce latency and throttling metricsDana Powers2016-07-171-4/+9
|
* Add base coordinator metricsDana Powers2016-07-173-76/+80
|
* Fix ProduceResponse v2 throttle_time_msDana Powers2016-07-171-1/+1
|
* Always encode size with MessageSet (#771)Dana Powers2016-07-172-5/+3
|
* Catch select errors while capturing test fixture logsDana Powers2016-07-171-1/+7
|
* Avoid buffer overread when compressing messageset in KafkaProducerDana Powers2016-07-171-1/+2
|
* Expand consumer.fetcher comment re comparing request / response offsetsDana Powers2016-07-171-1/+3
|
* Delete KafkaConnection class (#769)Dana Powers2016-07-173-398/+2
|
* KAFKA-3196: Add checksum and size to RecordMetadata and ConsumerRecord ↵Dana Powers2016-07-175-19/+38
| | | | (#770 / #594)
* Explicit format string argument indices for python 2.6 compatibilityDana Powers2016-07-173-4/+4
|
* Simplify RecordMetadata; short circuit callbacks (#768)Dana Powers2016-07-172-20/+9
| | | | Simplify RecordMetadata to unaltered namedtuple -- minor speed optimization Minor optimization: inline check for no callbacks
* KAFKA-3486: fix autocommit when partitions assigned manually (#767 / #626)Dana Powers2016-07-172-49/+8
|
* KAFKA-3117: handle metadata updates during consumer rebalance (#766 / #701)Dana Powers2016-07-172-11/+25
|
* KAFKA-2832: Add a consumer config option to exclude internal topics (#765)Dana Powers2016-07-172-4/+13
| | | | Use exclude_internal_topics config in KafkaConsumer to avoid subscribe patterns matching internal topics Raise error during rebalance if subscribed topics are not authorized
* 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-168-52/+154
|\ | | | | 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-165-40/+52
| |
| * 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-1611-27/+640
|\ \ | | | | | | Producer metrics + consumer/producer benchmark scripts
| * | Adapt benchmark scripts from https://github.com/mrafayaleem/kafka-jythonbenchmarksDana Powers2016-07-162-0/+337
| | |
| * | Move load_example.py to benchmarks/Dana Powers2016-07-161-0/+0
| | |
| * | 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-165-18/+261
| |/
* | #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-169-140/+146
|
* Include zk-offset configuration in coordinator unit testsDana Powers2016-07-161-2/+6
|
* Fix KafkaConsumer autocommit for 0.8 brokers (#756 / #706)Dana Powers2016-07-163-23/+27
| | | | * 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-153-1/+19
|
* Merge pull request #755 from dpkp/unrecurse_unpack_message_setDana Powers2016-07-152-17/+64
|\ | | | | Drop recursion in Fetcher _unpack_message_set
| * 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
|/
* Merge pull request #757 from dpkp/double_compressionDana Powers2016-07-142-16/+93
|\ | | | | Fix bug causing KafkaProducer to double-compress message batches
| * Fix bug causing KafkaProducer to double-compress message batches on retrydouble_compressionDana Powers2016-07-141-16/+23
| |
| * Test MessageSetBuffer close -- cover double close compression bugDana Powers2016-07-141-0/+70
|/
* Bump version for developmentDana Powers2016-07-101-1/+1
|
* Patch Release 1.2.41.2.4Dana Powers2016-07-083-1/+21
|
* Update consumer_timeout_ms docstring per #749Dana Powers2016-07-081-3/+3
|
View Lorry Controller Status