summaryrefslogtreecommitdiff
path: root/kafka/conn.py
Commit message (Collapse)AuthorAgeFilesLines
* Add protocol support for ApiVersionRequest; identify 0.10 brokers in ↵check_version_0_10Dana Powers2016-05-021-1/+2
| | | | check_version
* Improve socket disconnect handlingdisconnectsDana Powers2016-04-251-4/+22
|
* 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
|
* Add ssl support to BrokerConnectionDana Powers2016-04-091-3/+91
|
* Add state_change_callback to BrokerConnectionDana Powers2016-04-081-0/+8
|
* Move check_version() logic to BrokerConnectionDana Powers2016-04-081-0/+96
|
* Add BrokerConnection.disconnected() method; update testsDana Powers2016-04-081-0/+4
|
* Drop timeout param from BrokerConnection.recv()Dana Powers2016-04-081-8/+1
|
* Track last_failure in BrokerConnection.close()Dana Powers2016-04-071-2/+1
|
* Simplify connect logic furtherDana Powers2016-04-071-15/+14
|
* Use version-indexed lists for request/response protocol structsprotocol_versionsDana Powers2016-04-051-1/+1
|
* Update imports from kafka.common -> kafka.errors / kafka.structsDana Powers2016-04-051-2/+2
|
* Handle partial socket send()sock_send_bytesDana Powers2016-04-051-4/+6
|
* Improve Broker connection handling of not-ready nodesDana Powers2016-04-041-24/+26
| | | | | | | - simplify connect state logic - add connecting() method to check state - add BrokerConnection details to exceptions - return NodeNotReady as Future if still connecting
* Changed transltae to replace to support python 3Tim Evens2016-03-301-1/+2
|
* Kafka IPv6 Support.Tim Evens2016-03-301-6/+42
| | | | | | IPv6 address without port can be defined as the IPv6 address. If the address is a hostname or if a port is included, then the address MUST be wrapped in brackets [] (E.g. [somehost]:1234 or [fd00:1001::2]:1234).
* Handle windows socket error codes in BrokerConnectionDana Powers2016-03-171-4/+6
|
* Fix typo ifr.future.fail => ifr.future.failureMorten Lied Johansen2016-02-261-1/+1
|
* Dont override system rcvbuf or sndbuf unless user configures explicitlysocket_buffer_size_optionalDana Powers2016-02-171-6/+8
|
* Catch dns lookup errors when attempting to connect to nodesDana Powers2016-01-271-2/+8
|
* Warn on 0.8.2 GroupCoordinator no-topic-quirk, dont raise exceptionDana Powers2016-01-231-2/+5
|
* Pylint ignores to fix weird 2.7 error in new pylint versionDana Powers2016-01-231-0/+3
|
* Add DeprecationWarnings to legacy KafkaClient, Simple/MultiProcess/Consumer, ↵deprecation_warningsDana Powers2016-01-121-0/+3
| | | | and KafkaConnection
* Docstring updatesDana Powers2016-01-071-1/+10
|
* Catch py3 ConnectionErrorsDana Powers2016-01-031-7/+18
|
* Check for 0.8.2 GroupCoordinator quirk in BrokerConnectionDana Powers2016-01-031-1/+13
|
* Fix timeout bug in BrokerConnection.connect()Dana Powers2016-01-031-8/+9
|
* Fixup b6a2ad9: Fail with ConnectionErrors in BrokerConnection.sendDana Powers2016-01-021-2/+3
|
* Prefer assert or more-specific error to IllegalState / IllegalArgumentDana Powers2015-12-301-8/+3
|
* BrokerConnection: wrap socket errors in retriable ConnectionErrorDana Powers2015-12-301-3/+3
|
* Switch configs from attributes to dict to make passing / inspecting easierDana Powers2015-12-291-25/+31
|
* Use _next_correlation_id() method to avoid int overflowsDana Powers2015-12-291-4/+8
|
* Use ConnectionError rather than new DisconnectErrorDana Powers2015-12-291-2/+2
|
* Update BrokerConnection for use with async clientDana Powers2015-12-281-39/+74
| | | | | | | | | - use descriptive names for ConnectionStates enum values - Change default send_buffer_bytes config to 131072 - add can_send_more() and max_in_flight_requests_per_connection config - add blacked_out() and reconnect_backoff_ms config - last_attempt and last_failure are now public attributes - raise TooManyInFlightRequests in conn.send() if cant send more
* Switch BrokerConnection to (mostly) non-blocking IO.Dana Powers2015-12-171-81/+218
| | | | | | - return kafka.Future on send() - recv is now non-blocking call that completes futures when possible - update KafkaClient to block on future completion
* Check for no in-flight-requests in BrokerConnection.recvDana Powers2015-12-101-0/+3
|
* Move Request / Response logging from KafkaClient to BrokerConnectionDana Powers2015-12-101-2/+4
| | | | and reenable kafka.conn debug logging in tests
* Add next_correlation_id_recv + send helper methods to BrokerConnectionDana Powers2015-12-091-0/+8
|
* Support requests that do not expect a response in BrokerConnectionDana Powers2015-12-091-2/+3
|
* Exception handling cleanup in BrokerConnection (also catch struct.errors in ↵Dana Powers2015-12-091-4/+4
| | | | recv)
* Add client_id and correlation_id to BrokerConnection constructor kwargsDana Powers2015-12-091-3/+7
|
* Add size and correlation id decoding to try/except block in BrokerConnectionDana Powers2015-12-041-4/+5
|
* BrokerConnection:Dana Powers2015-12-041-11/+65
| | | | | | separate send / recv in BrokerConnection improve connection and error handling use different read and write fds for py3
* Add simple BrokerConnection class; add request.RESPONSE_TYPE class varsDana Powers2015-12-041-0/+36
|
* Merge pull request #473 from ecanzonieri/use_unblocking_io_for_aware_requestsDana Powers2015-12-021-0/+5
|\ | | | | Use unblocking io for broker aware requests
| * Unblocking broker aware requestEnrico Canzonieri2015-11-101-0/+5
| |
* | Support retry semantics in MultiProcessConsumerRoss Duggan2015-09-141-0/+4
|/
* Add a few extra docstring comments about thread-safe clients/connectionsDana Powers2015-06-081-3/+5
|
* Use separate module loggers instead of a single 'kafka' loggerDana Powers2015-06-061-1/+2
|
View Lorry Controller Status