| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | add kerberos domain name config for gssapi sasl mechanism handshake (#1542) | the-sea | 2018-08-31 | 1 | -2/+6 |
| | | |||||
| * | add support for smaller topic metadata fetch during bootstrap (#1541) | Ning Xie | 2018-08-31 | 1 | -3/+3 |
| | | |||||
| * | Improve connection handling when bootstrap list is invalid (#1507) | Dana Powers | 2018-05-26 | 1 | -6/+3 |
| | | | | | * only perform single dns lookup for connect_blocking() * fix blocking timeout in check_version() | ||||
| * | Stop shadowing `ConnectionError` | Jeff Widman | 2018-05-23 | 1 | -14/+14 |
| | | | | | | | | | | | In Python3, `ConnectionError` is a native exception. So rename our custom one to `KafkaConnectionError` to prevent accidentally shadowing the native one. Note that there are still valid uses of `ConnectionError` in this code. They already expect a native Python3 `ConnectionError`, and also already handle the Python2 compatibility issues. | ||||
| * | Improve BrokerConnection initialization (#1475) | Rômulo Rosa Furtado | 2018-04-15 | 1 | -1/+1 |
| | | |||||
| * | Fix KafkaConsumer docstring for request_timeout_ms default (#1459) | Dana Powers | 2018-03-23 | 1 | -2/+2 |
| | | |||||
| * | Connect with sockaddrs to support non-zero ipv6 scope ids (#1433) | Dana Powers | 2018-03-09 | 1 | -13/+10 |
| | | |||||
| * | Re-enable logging during broker version check (#1430) | Dana Powers | 2018-03-09 | 1 | -12/+1 |
| | | |||||
| * | Connection logging cleanups (#1432) | Dana Powers | 2018-03-09 | 1 | -4/+5 |
| | | |||||
| * | Add BrokerConnection.connect_blocking() (#1411) | Dana Powers | 2018-03-09 | 1 | -17/+47 |
| | | |||||
| * | Short-circuit BrokerConnection.close() if already disconnected (#1424) | Dana Powers | 2018-03-09 | 1 | -3/+6 |
| | | |||||
| * | Only increase reconnect backoff if all addrinfos have been tried (#1423) | Dana Powers | 2018-03-09 | 1 | -1/+4 |
| | | |||||
| * | Close leaked selector in version check (#1425) | Dana Powers | 2018-03-09 | 1 | -0/+1 |
| | | |||||
| * | Make BrokerConnection .host / .port / .afi immutable, use _sock_* attributes ↵ | Dana Powers | 2018-03-09 | 1 | -15/+25 |
| | | | | | for current lookups (#1422) | ||||
| * | Fix BrokerConnection.connection_delay() to return milliseconds (#1414) | Dana Powers | 2018-03-08 | 1 | -2/+9 |
| | | |||||
| * | use absolute imports everywhere (#1362) | Kevin Tindall | 2018-02-06 | 1 | -3/+3 |
| | | |||||
| * | Add Request/Response structs for kafka broker 1.0.0 | Dana Powers | 2018-02-06 | 1 | -0/+1 |
| | | |||||
| * | 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 |
| | | |||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |