| Commit message (Collapse) | Author | Age | Files | Lines | ||
|---|---|---|---|---|---|---|
| ... | ||||||
| * | Fix for Python 3 byte string handling in SASL auth (#1353) | Christophe Lecointe | 2018-01-24 | 1 | -2/+2 | |
| | | ||||||
| * | Honor reconnect_backoff in conn.connect() (#1342) | Dana Powers | 2018-01-11 | 1 | -1/+1 | |
| | | | | * Honor reconnect_backoff in conn.connect() | |||||
| * | Read all available socket bytes (#1332) | Dana Powers | 2018-01-10 | 1 | -22/+22 | |
| | | | | | * Recv all available network bytes before parsing * Add experimental support for configuring socket chunking parameters | |||||
| * | Improve KafkaConsumer cleanup (#1339) | Dana Powers | 2018-01-10 | 1 | -3/+9 | |
| | | ||||||
| * | Fix typo in _try_authenticate_plain (#1333) | everpcpc | 2017-12-28 | 1 | -1/+1 | |
| | | ||||||
| * | Add security layer negotiation to the GSSAPI authentication. (#1283) | Andre Araujo | 2017-12-26 | 1 | -22/+43 | |
| | | | | | | | | | | | | | | | | | | | When trying to establish a connection with Kafka using SASL with the GSSAPI authentication mechanism the connection was hanging an timing out after 60 secons. On the Kafka broker side I noticed that the SaslServerAuthenticator was going from the AUTHENTICATE to the FAILED state. The GSSAPI auth implementation was missing the second handshake defined in RFC 2222, which happens after the security context is established. This handshake is used by the client and server to negotiate the security layer (QoP) to be used for the connection. Kafka currently only support the "auth" QoP, so the implementation in this commit doesn't make it configurable, but this can be extended later. With this change I was able to successfully connect to a Kerberos-enabled Kafka broker using the SASL_PLAINTEXT protocol and the GSSAPI mechanism. | |||||
| * | KAFKA-3888 Use background thread to process consumer heartbeats (#1266) | Dana Powers | 2017-12-21 | 1 | -1/+1 | |
| | | ||||||
| * | Minor Exception cleanup | Jeff Widman | 2017-12-12 | 1 | -1/+1 | |
| | | ||||||
| * | Refactor dns lookup in BrokerConnection (#1312) | Dana Powers | 2017-12-08 | 1 | -61/+49 | |
| | | ||||||
| * | use python standard max value (#1303) | lukeWx | 2017-12-07 | 1 | -1/+1 | |
| | | ||||||
| * | changed for to use enumerate() (#1301) | Benn Roth | 2017-12-06 | 1 | -2/+1 | |
| | | ||||||
| * | Use socket timeout of request_timeout_ms to prevent blocking forever on send ↵ | Dana Powers | 2017-10-25 | 1 | -6/+7 | |
| | | | | | (#1281) | |||||
| * | Fix more gssapi errors (#1280) | Dana Powers | 2017-10-24 | 1 | -1/+4 | |
| | | ||||||
| * | Fixup for PR 1258 / _try_authenticate | Dana Powers | 2017-10-21 | 1 | -1/+4 | |
| | | ||||||
| * | Merge pull request #1258 from dpkp/pending_completions | Taras Voinarovskyi | 2017-10-21 | 1 | -14/+25 | |
| |\ | | | | | Move callback processing from BrokerConnection to KafkaClient | |||||
| | * | Move callback processing from BrokerConnection to KafkaClientpending_completions | Dana Powers | 2017-10-15 | 1 | -14/+25 | |
| | | | ||||||
| * | | Cleanup gssapi code; fix bug report re AttributeError. (#1262) | Dana Powers | 2017-10-16 | 1 | -10/+9 | |
| |/ | ||||||
| * | 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 | |
| | | ||||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |