| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Remove a few unused imports (#1188) | James Lamb | 2017-08-29 | 1 | -1/+2 |
| | | | | | | * Removed a few unused imports * Added note on socketpair monkey-path | ||||
| * | BrokerConnection receive bytes pipe (#1032) | Dana Powers | 2017-08-15 | 1 | -13/+3 |
| | | |||||
| * | Drop unused sleep kwarg to poll (#1177) | Dana Powers | 2017-08-15 | 1 | -9/+3 |
| | | |||||
| * | Select on sockets to avoid busy polling during bootstrap (#1175) | Dana Powers | 2017-08-13 | 1 | -0/+2 |
| | | |||||
| * | KIP-144: Exponential backoff for broker reconnections (#1124) | Dana Powers | 2017-06-19 | 1 | -19/+14 |
| | | |||||
| * | Fixup for #1085 -- only check for changed metadata on disconnected nodes | Dana Powers | 2017-06-18 | 1 | -17/+23 |
| | | |||||
| * | Deal with brokers that disappear, reappear with different IP address (#1085) | Mike Fischer | 2017-06-18 | 1 | -1/+12 |
| | | | | | | | | | | | | | | | | | | | | | When KafkaClient connects to a broker in _maybe_connect, it inserts into self._conns a BrokerConnection configured with the current host/port for that node. The BrokerConnection remains there forever, though, so if the broker's IP or host ever changes, KafkaClient has no way to deal with this. The fix is to compare the latest metadata with the current node's connection, and if the host/IP has changed, decommission the old connection and allow a new one to be created. There's also a common race condition on broker startup where the initial metadata request sometimes returns an empty list of brokers, but subsequent requests behave normally. So, we must deal with broker being None here. This change is conservative in that it doesn't remove the connection from self._conns unless the new broker metadata contains an entry for that same node with a new IP/port. | ||||
| * | Timeout idle connections via connections_max_idle_ms (#1068) | Dana Powers | 2017-04-10 | 1 | -1/+94 |
| | | |||||
| * | Avoid multiple connection attempts when refreshing metadata (#1067) | Dana Powers | 2017-04-05 | 1 | -44/+48 |
| | | |||||
| * | Catch socket.errors when sending / recving bytes on wake socketpair (#1069) | Dana Powers | 2017-04-05 | 1 | -2/+4 |
| | | |||||
| * | Fix poll() hyperlink in KafkaClient | Jeff Widman | 2017-03-29 | 1 | -1/+1 |
| | | | | Previously Sphinx was auto-linking to `poll()` in `KafkaConsumer`, so made the link explicit. | ||||
| * | Fix typo (#1054) | Jeff Widman | 2017-03-27 | 1 | -1/+1 |
| | | |||||
| * | Derive all api classes from Request / Response base classes (#1030) | Dana Powers | 2017-03-14 | 1 | -6/+1 |
| | | |||||
| * | Add optional kwarg to ready and is_ready to disable metadata-priority logic ↵ | Dana Powers | 2017-03-08 | 1 | -7/+16 |
| | | | | | (#1017) | ||||
| * | Add ClusterMetadata documentation | Dana Powers | 2017-03-07 | 1 | -0/+4 |
| | | |||||
| * | Fixup comment reference to _maybe_connect | Dana Powers | 2017-03-07 | 1 | -1/+1 |
| | | |||||
| * | Add client info logging re bootstrap; log connection attempts to balance ↵ | Dana Powers | 2017-03-06 | 1 | -0/+3 |
| | | | | | with close | ||||
| * | Added `max_bytes` option and FetchRequest_v3 usage. (#962) | Taras Voinarovskyi | 2017-03-06 | 1 | -0/+2 |
| | | | | | * Added `max_bytes` option and FetchRequest_v3 usage. * Add checks for versions above 0.10 based on ApiVersionResponse | ||||
| * | Fix BrokerConnection api_version docs default (#909) | Jeff Widman | 2017-02-28 | 1 | -4/+4 |
| | | |||||
| * | PEP-8: Spacing & removed unused imports (#899) | Jeff Widman | 2017-02-09 | 1 | -11/+11 |
| | | |||||
| * | Move docstring so it shows up in Sphinx/RTD (#952) | Jeff Widman | 2017-01-21 | 1 | -83/+83 |
| | | |||||
| * | Use connection state functions where possible | Dana Powers | 2017-01-19 | 1 | -3/+3 |
| | | |||||
| * | Pass error to BrokerConnection.close() | Dana Powers | 2017-01-19 | 1 | -1/+1 |
| | | |||||
| * | Fix possible request draining in ensure_active_group (#896) | Dana Powers | 2016-12-02 | 1 | -9/+10 |
| | | |||||
| * | DOC: Fix typo 'Defualt' -> 'Default'. (#895) | Rolando (Max) Espinoza | 2016-11-30 | 1 | -1/+1 |
| | | |||||
| * | setting proper topic value in case if it's empty (#867) | Alexander Sibiryakov | 2016-11-18 | 1 | -11/+4 |
| | | |||||
| * | Always check for request timeouts (#887) | Dana Powers | 2016-11-18 | 1 | -0/+8 |
| | | | | | * Check for requests that timeout without causing a socket read/write event | ||||
| * | Fix typos | Jeff Widman | 2016-11-14 | 1 | -2/+2 |
| | | |||||
| * | Added ssl_password config option to KafkaProducer class, identical to… (#830) | kierkegaard13 | 2016-09-15 | 1 | -0/+2 |
| | | | | | | | | | * Added ssl_password config option to KafkaProducer class, identical to option in KafkaConsumer class * removed non-ascii characters * changed - to : in comments | ||||
| * | Instrument metrics in BrokerConnection | Dana Powers | 2016-08-04 | 1 | -0/+2 |
| | | |||||
| * | Add connection-count to KafkaClient metrics | Dana Powers | 2016-08-04 | 1 | -3/+12 |
| | | |||||
| * | Add connection-creation-rate / connection-close-rate to KafkaClientMetrics | Dana Powers | 2016-08-04 | 1 | -0/+13 |
| | | |||||
| * | Fix misspelling of "password" (#793) | Samuel Taylor | 2016-08-04 | 1 | -1/+1 |
| | | |||||
| * | Ignore socket.error when checking for protocol out of sync prior to socket ↵ | Dana Powers | 2016-08-03 | 1 | -4/+7 |
| | | | | | close (#792) | ||||
| * | implement sasl PLAIN mechanism | Lars Jørgen Solberg | 2016-08-03 | 1 | -0/+10 |
| | | |||||
| * | Vendor six 1.10.0six | Dana Powers | 2016-08-01 | 1 | -1/+1 |
| | | |||||
| * | Move kafka.socketpair to kafka.vendor.socketpair | Dana Powers | 2016-08-01 | 1 | -1/+1 |
| | | |||||
| * | Move kafka.selectors34 to kafka.vendor.selectors34 | Dana Powers | 2016-08-01 | 1 | -1/+1 |
| | | |||||
| * | Use socket_options configuration to setsockopts(). Default TCP_NODELAY (#783) | Dana Powers | 2016-08-01 | 1 | -7/+11 |
| | | |||||
| * | Add KafkaClient metricsmore_metrics | Dana Powers | 2016-07-17 | 1 | -1/+51 |
| | | |||||
| * | Explicit format string argument indices for python 2.6 compatibility | Dana Powers | 2016-07-17 | 1 | -1/+1 |
| | | |||||
| * | Expose selector type as config option (#764) | Dana Powers | 2016-07-16 | 1 | -1/+5 |
| | | |||||
| * | Protect writes to wakeup socket with threading lock (#763 / #709) | Dana Powers | 2016-07-16 | 1 | -2/+6 |
| | | |||||
| * | Use MetadataRequest v1 for 0.10+ api_versionmetadata_v1 | Dana Powers | 2016-07-16 | 1 | -3/+14 |
| | | |||||
| * | Add api_version config to KafkaClient, deprecate str in favor of tuples (#761) | Dana Powers | 2016-07-16 | 1 | -2/+28 |
| | | |||||
| * | Add ssl_password to default_config dicts. Send ssl_password when loading ↵ | Ashley McKemie | 2016-07-08 | 1 | -0/+1 |
| | | | | | cert chains (#750) | ||||
| * | Wakeup socket optimizations (#740) | Dana Powers | 2016-06-26 | 1 | -1/+1 |
| | | |||||
| * | Avoid busy poll during metadata refresh failure with retry_backoff_ms (#733) | Dana Powers | 2016-06-20 | 1 | -30/+43 |
| | | |||||
| * | check_version should scan nodes until version found or timeout (#731) | Dana Powers | 2016-06-19 | 1 | -12/+41 |
| | | | | | | * Mute all connection logging during conn.check_version * Always process pending MetadataRequest in conn.check_version * KakfaClient.check_version: Scan all brokers until a version is identified or timeout | ||||
| * | Update KafkaClient.least_loaded_node (#730) | Dana Powers | 2016-06-18 | 1 | -23/+17 |
| | | | | | | | - Main node loop should check all known brokers, not just conn objects, which is consistent with the official java client. - This fixes a bug which could cause least_loaded_node to always return the same unavailable node | ||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |