summaryrefslogtreecommitdiff
Commit message (Expand)AuthorAgeFilesLines
* Ignore socket.error when checking for protocol out of sync prior to socket closecatch_socket_errorDana 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
* 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 (#770...Dana Powers2016-07-175-19/+38
* 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
* 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
* 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 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
|\ \
| * | 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