| Commit message (Collapse) | Author | Age | Files | Lines | ||
|---|---|---|---|---|---|---|
| ... | ||||||
| * | Remove a few unused imports (#1188) | James Lamb | 2017-08-29 | 4 | -4/+3 | |
| | | | | | | * Removed a few unused imports * Added note on socketpair monkey-path | |||||
| * | BrokerConnection receive bytes pipe (#1032) | Dana Powers | 2017-08-15 | 4 | -93/+121 | |
| | | ||||||
| * | Drop unused sleep kwarg to poll (#1177) | Dana Powers | 2017-08-15 | 4 | -14/+9 | |
| | | ||||||
| * | bump version for development | Dana Powers | 2017-08-13 | 1 | -1/+1 | |
| | | ||||||
| * | Release 1.3.41.3.4 | Dana Powers | 2017-08-13 | 1 | -1/+1 | |
| | | ||||||
| * | Initialize metadata_snapshot in group coordinator (#1174) | Dana Powers | 2017-08-13 | 1 | -6/+9 | |
| | | ||||||
| * | Select on sockets to avoid busy polling during bootstrap (#1175) | Dana Powers | 2017-08-13 | 1 | -0/+2 | |
| | | ||||||
| * | Added unit tests for fetcher's `_reset_offset` and related functions. | Taras Voinarovskiy | 2017-08-07 | 1 | -5/+16 | |
| | | ||||||
| * | Added `beginning_offsets` and `end_offsets` API's and fixed @jeffwidman ↵ | Taras Voinarovskiy | 2017-08-07 | 3 | -16/+96 | |
| | | | | | review issues | |||||
| * | Fix test for older brokers | Taras Voinarovskiy | 2017-08-07 | 1 | -1/+1 | |
| | | ||||||
| * | Changed retrieve_offsets to allow fetching multiple offsets at once | Taras Voinarovskiy | 2017-08-07 | 2 | -96/+133 | |
| | | ||||||
| * | Added basic support for offsets_for_times API. Still needs to group by nodes ↵ | Taras Voinarovskiy | 2017-08-07 | 5 | -20/+124 | |
| | | | | | and send in parallel. | |||||
| * | Add private map of api key -> min/max versions to BrokerConnection (#1169) | Dana Powers | 2017-08-06 | 2 | -11/+58 | |
| | | ||||||
| * | Fixed Issue 1033.Raise AssertionError when decompression unsupported. (#1159) | webber | 2017-08-05 | 1 | -0/+7 | |
| | | ||||||
| * | conn: Catch ssl.EOFErrors on Python3.3 so we close the failing conn (#1162) | Hannu Valtonen | 2017-08-01 | 1 | -1/+3 | |
| | | ||||||
| * | Make UnknownTopicOrPartitionError retriable errorissue1155 | Taras Voinarovskiy | 2017-07-30 | 1 | -0/+1 | |
| | | ||||||
| * | Fix batch expiry messages to state seconds | Dominic Evans | 2017-07-26 | 1 | -3/+3 | |
| | | | | | | time.time() is seconds since epoch, and the deltas are also calculated in seconds | |||||
| * | Use for join-time-max and sync-time-max metrics Max() measure function (#1146) | Alexey Pervushin | 2017-07-20 | 1 | -2/+2 | |
| | | ||||||
| * | added gssapi support (Kerberos) for SASL (#1152) | Harald | 2017-07-20 | 1 | -2/+75 | |
| | | ||||||
| * | Add note, that `max_in_flight_requests_per_connection>1` may change order or ↵ | Taras Voinarovskyi | 2017-07-17 | 1 | -1/+4 | |
| | | | | | messages (#1149) | |||||
| * | producer: fix produce timeout message (#1151) | Mika Eloranta | 2017-07-17 | 1 | -1/+1 | |
| | | ||||||
| * | Protocol updates for 0.11.0.0 (#1127) | Dana Powers | 2017-07-09 | 7 | -41/+508 | |
| | | ||||||
| * | Use logging's built-in string interpolation | Jeff Widman | 2017-07-07 | 2 | -6/+5 | |
| | | ||||||
| * | change_subscription called only when necessary (#1132) | Petr Šebek | 2017-07-07 | 1 | -2/+3 | |
| | | | | | | | When we are using subscription by pattern change subscription is called every metadata update even when nothing changes. This PR ensures that change subscription is called only when set of topics changes. | |||||
| * | producer: Set exit timeout to 0 for atexit handler to match __del__ (#1126) | Hannu Valtonen | 2017-06-19 | 1 | -1/+1 | |
| | | | | | | | | | Hit a problem with pytest hitting the atexit handler and waiting for close() timeout forever at teardown. This commit makes atexit close() equivalent to __del__ behavior, namely using timeout of 0 for close() completion. If you need a longer timeout you should be setting it explicitly. | |||||
| * | KIP-144: Exponential backoff for broker reconnections (#1124) | Dana Powers | 2017-06-19 | 4 | -22/+69 | |
| | | ||||||
| * | Backoff on unavailable group coordinator retry (#1125) | Dana Powers | 2017-06-19 | 1 | -0/+2 | |
| | | ||||||
| * | 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. | |||||
| * | Describe consumer thread-safety | Linus Wallgren | 2017-06-16 | 1 | -0/+2 | |
| | | ||||||
| * | Update exception docstring | Andrew Kowalik | 2017-06-16 | 1 | -1/+1 | |
| | | ||||||
| * | raise KafkaTimeoutException when flush times out | Andrew Kowalik | 2017-06-16 | 2 | -2/+9 | |
| | | ||||||
| * | Improve error message when expiring batches in KafkaProducer (#1077) | Dana Powers | 2017-05-03 | 1 | -7/+11 | |
| | | ||||||
| * | Warn dont raise on DNS lookup failures (#1091) | Dana Powers | 2017-05-03 | 1 | -5/+7 | |
| | | ||||||
| * | Follow-up to #1068: remove not-implemented comments | Dana Powers | 2017-04-10 | 2 | -2/+2 | |
| | | ||||||
| * | Timeout idle connections via connections_max_idle_ms (#1068) | Dana Powers | 2017-04-10 | 3 | -4/+99 | |
| | | ||||||
| * | 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 | |
| | | ||||||
| * | Bump version for development | Dana Powers | 2017-03-14 | 1 | -1/+1 | |
| | | ||||||
| * | Release 1.3.31.3.3 | Dana Powers | 2017-03-14 | 1 | -1/+1 | |
| | | ||||||
| * | Derive all api classes from Request / Response base classes (#1030) | Dana Powers | 2017-03-14 | 11 | -84/+140 | |
| | | ||||||
| * | LZ4 support in kafka 0.8/0.9 does not accept a ContentSize header | Dana Powers | 2017-03-14 | 1 | -6/+14 | |
| | | ||||||
| * | Prefer python-lz4 over lz4f if available | Dana Powers | 2017-03-14 | 1 | -7/+32 | |
| | | ||||||
| * | Free lz4 decompression context to avoid leak | Dana Powers | 2017-03-14 | 1 | -0/+1 | |
| | | ||||||
| * | Avoid re-encoding for message crc check (#1027) | Dana Powers | 2017-03-13 | 1 | -6/+12 | |
| | | ||||||
| * | Additional docstrings for autocommit close option | Dana Powers | 2017-03-13 | 3 | -3/+17 | |
| | | ||||||
| * | Optionally skip auto-commit during consumer.close (#1031) | Dana Powers | 2017-03-13 | 2 | -4/+5 | |
| | | ||||||
| * | Return copy of consumer subscription set (#1029) | Dana Powers | 2017-03-13 | 1 | -1/+1 | |
| | | ||||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |