summaryrefslogtreecommitdiff
Commit message (Expand)AuthorAgeFilesLines
* Use new release 0.10.0.1 for 0.10 testing0.10.0.1Dana Powers2016-08-113-5/+5
* Add 0.10.0.1 fixture resourcesDana Powers2016-08-113-0/+188
* Bump version for developmentDana Powers2016-08-111-1/+1
* Patch Release 1.3.11.3.1Dana Powers2016-08-083-1/+15
* HOTFIX: Fix BrokerConnectionMetrics when sensors already exist (i.e., on reco...Dana Powers2016-08-081-11/+15
* Bump version for developmentDana Powers2016-08-041-1/+1
* Release 1.3.01.3.0Dana Powers2016-08-044-2/+120
* Dump fixture logs on failureDana Powers2016-08-041-0/+2
* Drain pending requests to the coordinator before initiating group rejoin (#798)Dana Powers2016-08-041-0/+8
* Send combined size and payload bytes to socket to avoid potentially split pac...Dana Powers2016-08-041-6/+6
* Merge pull request #796 from dpkp/fixture_auto_portsDana Powers2016-08-043-32/+27
|\
| * Dont include kafka.vendor in coveragefixture_auto_portsDana Powers2016-08-042-3/+6
| * Try to bind to a new port on fixture failure retriesDana Powers2016-08-041-29/+21
|/
* Change coordinator.needs_join_prepare -> coordinator.rejoining; fix consumer ...Dana Powers2016-08-042-5/+10
* Merge pull request #794 from dpkp/conn_metricsDana Powers2016-08-0413-49/+253
|\
| * Instrument bufferpool-wait-ratio metric in KafkaProducerconn_metricsDana Powers2016-08-043-8/+17
| * Instrument metrics in BrokerConnectionDana Powers2016-08-044-17/+127
| * Treat metric_group_prefix as config in KafkaConsumerDana Powers2016-08-046-19/+17
| * Metrics instance must be passed explicitly from KafkaConsumer to KafkaClientDana Powers2016-08-041-1/+1
| * Remove unused import from kafka.connDana Powers2016-08-041-1/+1
| * Add BrokerConnection docstring with configuration parametersDana Powers2016-08-041-0/+65
| * Add connection-count to KafkaClient metricsDana Powers2016-08-041-3/+12
| * Add connection-creation-rate / connection-close-rate to KafkaClientMetricsDana Powers2016-08-041-0/+13
|/
* Fix misspelling of "password" (#793)Samuel Taylor2016-08-043-3/+3
* Ignore socket.error when checking for protocol out of sync prior to socket cl...Dana Powers2016-08-031-4/+7
* Support for PLAIN sasl authentication (PR #779)Dana Powers2016-08-036-5/+179
|\
| * minor tweaks to get authentication workingLars Jørgen Solberg2016-08-031-8/+7
| * Use callbacks for sasl handshake request / responseDana Powers2016-08-031-59/+62
| * implement sasl PLAIN mechanismLars Jørgen Solberg2016-08-036-4/+176
|/
* Always absolute_importabsolute_importDana Powers2016-08-0259-0/+121
* Rename partition_assignment -> assignment in MemberMetadata for consistencyDana Powers2016-08-021-1/+1
* Clarify api_version=str deprecation warningDana Powers2016-08-022-2/+2
* Metadata with_partitions() (#787)Dana Powers2016-08-011-1/+20
* Merge pull request #785 from dpkp/sixDana Powers2016-08-0127-30/+902
|\
| * Vendor six 1.10.0sixDana Powers2016-08-0125-27/+899
| * Move kafka.socketpair to kafka.vendor.socketpairDana Powers2016-08-012-1/+1
| * Move kafka.selectors34 to kafka.vendor.selectors34Dana Powers2016-08-014-2/+2
* | Fix offset fetch when partitions are manually assigned (#786)Dana Powers2016-08-011-0/+1
* | Rename _DEFAULT_CONFIG -> DEFAULT_CONFIG in KafkaProducer (#788)Dana Powers2016-08-013-6/+6
|/
* Use socket_options configuration to setsockopts(). Default TCP_NODELAY (#783)Dana Powers2016-08-014-17/+39
* Document the ssl_password config option (#780)Samuel Taylor2016-07-261-0/+2
* Merge pull request #772 from dpkp/more_metricsDana Powers2016-07-266-82/+142
|\
| * 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
* | change pickle_method to use python3 special attributes (#777)John Win2016-07-261-3/+9
* | Fix typo in KafkaConsumer documentation (#775)Samuel Taylor2016-07-211-1/+1
|/
* 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