| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Move callback processing from BrokerConnection to KafkaClientpending_completions | Dana Powers | 2017-10-15 | 1 | -14/+25 |
| | | |||||
| * | Fix SASL authentication bugs (#1257) | Dana Powers | 2017-10-15 | 1 | -23/+34 |
| | | | | | | | * Use _send_bytes_blocking in BrokerConnection * _try_authenticate should call recv() so that futures are resolved * _sasl_auth_future can be reset if recv() causes disconnect * validate sasl_mechanism against SaslHandShakeResponse enabled_mechanisms | ||||
| * | Check for disconnects during ssl handshake and sasl authentication (#1249) | Dana Powers | 2017-10-10 | 1 | -31/+42 |
| | | |||||
| * | Always wait for completion during SASL/GSSAPI authentication (#1248) | Dana Powers | 2017-10-10 | 1 | -26/+15 |
| | | |||||
| * | Add kafka.protocol.parser.KafkaProtocol w/ receive and send (#1230) | Dana Powers | 2017-10-10 | 1 | -145/+44 |
| | | |||||
| * | Fix typo | Jeff Widman | 2017-10-06 | 1 | -1/+1 |
| | | |||||
| * | Small fixes to SASL documentation and logging; validate security_protocol ↵ | Dana Powers | 2017-10-03 | 1 | -21/+26 |
| | | | | | (#1231) | ||||
| * | Remove raw traceback (#1221) | dbgasaway | 2017-10-01 | 1 | -3/+5 |
| | | |||||
| * | Remove a few unused imports (#1188) | James Lamb | 2017-08-29 | 1 | -1/+0 |
| | | | | | | * Removed a few unused imports * Added note on socketpair monkey-path | ||||
| * | BrokerConnection receive bytes pipe (#1032) | Dana Powers | 2017-08-15 | 1 | -77/+84 |
| | | |||||
| * | Added `beginning_offsets` and `end_offsets` API's and fixed @jeffwidman ↵ | Taras Voinarovskiy | 2017-08-07 | 1 | -1/+1 |
| | | | | | review issues | ||||
| * | Added basic support for offsets_for_times API. Still needs to group by nodes ↵ | Taras Voinarovskiy | 2017-08-07 | 1 | -0/+1 |
| | | | | | and send in parallel. | ||||
| * | Add private map of api key -> min/max versions to BrokerConnection (#1169) | Dana Powers | 2017-08-06 | 1 | -11/+21 |
| | | |||||
| * | conn: Catch ssl.EOFErrors on Python3.3 so we close the failing conn (#1162) | Hannu Valtonen | 2017-08-01 | 1 | -1/+3 |
| | | |||||
| * | added gssapi support (Kerberos) for SASL (#1152) | Harald | 2017-07-20 | 1 | -2/+75 |
| | | |||||
| * | Use logging's built-in string interpolation | Jeff Widman | 2017-07-07 | 1 | -4/+4 |
| | | |||||
| * | KIP-144: Exponential backoff for broker reconnections (#1124) | Dana Powers | 2017-06-19 | 1 | -3/+37 |
| | | |||||
| * | Warn dont raise on DNS lookup failures (#1091) | Dana Powers | 2017-05-03 | 1 | -5/+7 |
| | | |||||
| * | Timeout idle connections via connections_max_idle_ms (#1068) | Dana Powers | 2017-04-10 | 1 | -2/+4 |
| | | |||||
| * | Derive all api classes from Request / Response base classes (#1030) | Dana Powers | 2017-03-14 | 1 | -4/+4 |
| | | |||||
| * | Add client info logging re bootstrap; log connection attempts to balance ↵ | Dana Powers | 2017-03-06 | 1 | -1/+1 |
| | | | | | with close | ||||
| * | Small cleanup for #962 | Dana Powers | 2017-03-06 | 1 | -4/+9 |
| | | |||||
| * | Added `max_bytes` option and FetchRequest_v3 usage. (#962) | Taras Voinarovskyi | 2017-03-06 | 1 | -1/+24 |
| | | | | | * Added `max_bytes` option and FetchRequest_v3 usage. * Add checks for versions above 0.10 based on ApiVersionResponse | ||||
| * | Add more debug-level connection logging | Dana Powers | 2017-03-06 | 1 | -0/+7 |
| | | |||||
| * | Do not need str(self) when formatting to %s | Dana Powers | 2017-03-06 | 1 | -16/+16 |
| | | |||||
| * | When closing a broker connection without error, fail in-flight-requests with ↵ | Dana Powers | 2017-03-03 | 1 | -1/+1 |
| | | | | | Cancelled (#1010) | ||||
| * | Include the node id in BrokerConnection __repr__ (#1009) | Dana Powers | 2017-03-03 | 1 | -2/+2 |
| | | |||||
| * | Mark last_attempt time during connection close to fix blackout calculation ↵ | Dana Powers | 2017-03-03 | 1 | -0/+1 |
| | | | | | (#1008) | ||||
| * | Catch socket errors during ssl handshake (#1007) | Dana Powers | 2017-03-03 | 1 | -1/+1 |
| | | |||||
| * | Fix sasl reconnect bug: auth future must be reset on close (#1003) | Dana Powers | 2017-03-03 | 1 | -0/+1 |
| | | |||||
| * | Fix BrokerConnection api_version docs default (#909) | Jeff Widman | 2017-02-28 | 1 | -4/+3 |
| | | |||||
| * | Move BrokerConnection docstring to class (#968) | Jeff Widman | 2017-02-08 | 1 | -68/+69 |
| | | |||||
| * | Add support for Python built without ssl (#939) (#954) | Sho Minagawa | 2017-02-03 | 1 | -17/+28 |
| | | |||||
| * | Do not re-close a disconnected connection | Dana Powers | 2017-01-19 | 1 | -1/+0 |
| | | |||||
| * | Drop unused last_failure time from BrokerConnection | Dana Powers | 2017-01-19 | 1 | -4/+1 |
| | | |||||
| * | Use connection state functions where possible | Dana Powers | 2017-01-19 | 1 | -0/+1 |
| | | |||||
| * | Pass error to BrokerConnection.close() | Dana Powers | 2017-01-19 | 1 | -19/+27 |
| | | |||||
| * | Fix typo: coorelation --> correlation (#929) | Jeff Widman | 2017-01-11 | 1 | -5/+5 |
| | | |||||
| * | Make SSL warning list the correct Python versions (#924) | Jeff Widman | 2017-01-04 | 1 | -3/+3 |
| | | |||||
| * | Bug fix: ret = err => ret = err.errno (#907) | guojh | 2016-12-17 | 1 | -1/+1 |
| | | |||||
| * | Fixup doc references to max_in_flight_requests_per_connection | Dana Powers | 2016-12-17 | 1 | -1/+1 |
| | | |||||
| * | Fix typo: passowrd --> password (#901) | Jeff Widman | 2016-12-12 | 1 | -1/+1 |
| | | |||||
| * | DOC: Fix typo 'Defualt' -> 'Default'. (#895) | Rolando (Max) Espinoza | 2016-11-30 | 1 | -1/+1 |
| | | |||||
| * | When hostname lookup is necessary, do every connect (#812) | Evan Bender | 2016-11-20 | 1 | -5/+9 |
| | | | | | | Fixes a bug where lookup was done only once for the whole life of the process -- if a broker's IP changed, client couldn't reconnect. | ||||
| * | Always check for request timeouts (#887) | Dana Powers | 2016-11-18 | 1 | -4/+4 |
| | | | | | * Check for requests that timeout without causing a socket read/write event | ||||
| * | typo (#883) | sharego | 2016-11-15 | 1 | -1/+1 |
| | | | | type error | ||||
| * | Update param in warning (#878) | Dana Powers | 2016-11-14 | 1 | -2/+2 |
| |\ | | | | | In Kafka 9, advertised.host.name was renamed to advertised.listeners | ||||
| | * | Update param in warning | Jeff Widman | 2016-11-11 | 1 | -2/+2 |
| | | | | | | | In Kafka 9, advertised.host.name was renamed to advertised.listeners | ||||
| * | | Fix typos | Jeff Widman | 2016-11-14 | 1 | -2/+2 |
| |/ | |||||
| * | Monkeypatch max_in_flight_requests_per_connection when checking broker ↵ | Dana Powers | 2016-09-28 | 1 | -6/+11 |
| | | | | | version (#834) | ||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |