summaryrefslogtreecommitdiff
path: root/kafka
Commit message (Collapse)AuthorAgeFilesLines
* Catch response decode errors and log detailsdecode_errorsDana Powers2016-06-011-1/+14
|
* Bump version for developmentDana Powers2016-05-241-1/+1
|
* Release 1.2.01.2.0Dana Powers2016-05-241-1/+1
|
* KAFKA-3388: Fix expiration of batches sitting in the accumulator (#699)Dana Powers2016-05-221-7/+39
|
* KAFKA-3197: when max.in.flight.request.per.connection = 1, attempt to ↵Dana Powers2016-05-223-11/+33
| | | | guarantee ordering (#698)
* Dont use soon-to-be-reserved keyword await as function name ↵Dana Powers2016-05-222-3/+3
| | | | (FutureProduceResult) (#697)
* Fix socket leaks in KafkaClient (#696)Dana Powers2016-05-221-10/+10
| | | | | * Cleanup wakeup socketpair on close to avoid leak in KafkaClient * Cleanup unneeded bootstrap connection to avoid leak in KafkaClient * Dont warn on socket disconnections caused by KafkaClient.close()
* Use standard LZ4 framing for v1 messages / kafka 0.10 (#695)Dana Powers2016-05-224-12/+39
| | | | | | * LZ4 framing fixed in 0.10 / message v1 -- retain broken lz4 code for compatibility * lz4f does not support easy incremental decompression - raise RuntimeError * Update lz4 codec tests
* Use Fetch/Produce API v2 for brokers >= 0.10 (uses message format v1) (#694)Dana Powers2016-05-226-9/+66
|
* KAFKA-3025: Message v1 -- add timetamp and use relative offset in compressed ↵Dana Powers2016-05-227-50/+132
| | | | messagesets
* Always pass encoded message bytes to MessageSet.encode()Dana Powers2016-05-222-40/+22
|
* raise ValueError on protocol encode/decode errorsDana Powers2016-05-221-15/+32
|
* Add CRL support to SSL support (#683)Vincent Bernat2016-05-194-0/+29
| | | | A user can provide a CRL whose peer certificate will be checked against. This only works with Python 3.4+ and Python 2.7.9+.
* Fixup BrokerConnection check_version strict error checking: 0.9 will fail ↵Dana Powers2016-05-171-0/+7
| | | | with CorrelationIdError
* supplement socket.gaierror exception in BrokerConnection.connect() (#687)Erik Beebe2016-05-171-3/+10
| | | supplement socket.gaierror exception to include the host/port
* kafka/conn: use original hostname for SSL checks (#682)Vincent Bernat2016-05-171-2/+4
| | | | | | | | When the address family is not provided, `self.host` is resolved to one of the IP addresses and replaced by it. The SSL context is then built using `self.host` which is now an IP instead of the proper name. Most of the time, hostname cannot be checked this way. Therefore, save the original hostname in a dedicated property and use this property for the SSL context.
* * [SimpleConsumer] Fix legacy SimpleConsumer when using compressed messages* ↵Paul Cavallaro2016-05-101-2/+12
| | | | | [Legacy Protocol] Update legacy protocol to handle compressed messages * [SimpleConsumer] Fix legacy SimpleConsumer when using compressed messages
* Merge pull request #679 from zackdever/kafka-PR-1265-bugfixZack Dever2016-05-031-1/+1
|\ | | | | small bug fix in Sensor
| * small bug fix in SensorZack Dever2016-05-031-1/+1
| | | | | | pulling in this small bug fix from https://github.com/apache/kafka/pull/1265/files#diff-8736b7fd8ad077ea55ea2a8ad61285faR99
* | Add protocol support for ApiVersionRequest; identify 0.10 brokers in ↵check_version_0_10Dana Powers2016-05-024-3/+26
|/ | | | check_version
* Patch release: 1.1.11.1.1Dana Powers2016-04-251-1/+1
|
* Improve socket disconnect handlingdisconnectsDana Powers2016-04-252-5/+23
|
* Disable standard metadata refresh hook during bootstrapDana Powers2016-04-251-0/+2
|
* handle unexpected reads in client_asyncJames Brown2016-04-251-0/+19
| | | | Should fix #661.
* use the same logic for callbacks regardless of is_done statusZack Dever2016-04-251-12/+15
|
* Fix throttle_time_ms sensorZack Dever2016-04-251-1/+2
| | | Fixes #665
* Avoid some exceptions in Coordinator.__del__ (#668)Dana Powers2016-04-252-2/+4
|
* Bump version for developmentDana Powers2016-04-251-1/+1
|
* Release 1.1.0Dana Powers2016-04-241-1/+1
|
* More thorough IPv6 support that uses getaddrinfo to resolve namesJames Brown2016-04-241-24/+99
| | | | Fixes #641
* Wait for future.is_done in check_version (fix for windows)Dana Powers2016-04-241-5/+5
|
* Merge pull request #649 from jayalane/masterDana Powers2016-04-241-2/+4
|\ | | | | to squelch the __del issue
| * as per code reviewChris Lane2016-04-141-2/+2
| |
| * to squelch the __del issueChris Lane2016-04-131-2/+4
| |
* | instrument metrics for fetch requestsZack Dever2016-04-132-65/+93
| |
* | trying to use locks a little less. still not ideal.Zack Dever2016-04-134-19/+18
| |
* | Changing some commented out metrics to avoid future gotchas.Zack Dever2016-04-132-4/+4
| |
* | Beginnings of metrics instrumentation in kafka consumer.Zack Dever2016-04-132-47/+53
| | | | | | | | | | | | This adds the parent metrics instance to kafka consumer, which will eventually be used to instrument everything under consumer. To start I ported the java consumer coordinator metrics.
* | Basic dictionary reporter in place of the java JMX reporter.Zack Dever2016-04-132-1/+84
| |
* | Kafka metrics java port. No reporters or instrumentation.Zack Dever2016-04-1324-0/+1250
|/ | | | | There is no straight translation for the JMX reporter into python, so I'll do something else in a separate commit.
* Add SSL configuration kwargs to KafkaClient, KafkaConsumer, KafkaProducerDana Powers2016-04-093-0/+63
|
* Check for pending ssl bytes in KafkaClient loopDana Powers2016-04-091-0/+12
|
* Handle SSL HANDSHAKE state in KafkaClient state change handlerDana Powers2016-04-091-2/+4
|
* Add ssl support to BrokerConnectionDana Powers2016-04-091-3/+91
|
* Use selectors module in KafkaClientselectorsDana Powers2016-04-091-32/+33
|
* Vendor selectors34 moduleDana Powers2016-04-081-0/+635
|
* Add state_change_callback to bootstrap connectionconn_state_callbackDana Powers2016-04-081-1/+4
|
* Drop bootstrap connection once first normal broker is connectedDana Powers2016-04-081-0/+6
|
* Add private _refresh_on_disconnects flag to KafkaClientDana Powers2016-04-081-2/+8
|
* Move state logic from KafkaClient._maybe_connect to _conn_state_change as ↵Dana Powers2016-04-081-19/+19
| | | | callback
View Lorry Controller Status