| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Cover sticky assignor's metadata method with tests (#2161) | Valeria Chernenko | 2020-11-05 | 1 | -3/+7 |
| | | |||||
| * | Use six.viewitems instead of six.iteritems to avoid encoding problems (#2154) | Valeria Chernenko | 2020-10-30 | 1 | -1/+1 |
| | | |||||
| * | KIP-54: Implement sticky partition assignment strategy (#2057) | Valeria Chernenko | 2020-09-29 | 5 | -1/+897 |
| | | |||||
| * | Fix #1985: fix consumer deadlock when heartbeat thread request timeout (#2064) | huangcuiyang | 2020-09-07 | 1 | -8/+12 |
| | | |||||
| * | remove unused imports | James Lamb | 2020-07-10 | 1 | -1/+0 |
| | | |||||
| * | Optionally return OffsetAndMetadata from consumer.committed(tp) (#1979) | Dana Powers | 2019-12-29 | 1 | -3/+3 |
| | | |||||
| * | Log retriable coordinator NodeNotReady, TooManyInFlightRequests as debug not ↵ | Dana Powers | 2019-12-29 | 1 | -2/+5 |
| | | | | | error (#1975) | ||||
| * | Fix simple typo: managementment -> management | Tim Gates | 2019-12-08 | 1 | -1/+1 |
| | | | | | Closes #1965 | ||||
| * | Fix typos | Carson Ip | 2019-11-08 | 1 | -1/+1 |
| | | |||||
| * | Issue #1780 - Consumer hang indefinitely in fetcher._retrieve_offsets() due ↵ | Commander Dishwasher | 2019-09-30 | 1 | -1/+5 |
| | | | | | to topic deletion while rebalancing (#1782) | ||||
| * | Change coordinator lock acquisition order (#1821) | Dana Powers | 2019-09-29 | 1 | -42/+36 |
| | | |||||
| * | Wrap consumer.poll() for KafkaConsumer iteration (#1902) | Dana Powers | 2019-09-28 | 1 | -1/+5 |
| | | |||||
| * | Allow the coordinator to auto-commit for all api_version. | Jay Chan | 2019-06-20 | 1 | -1/+1 |
| | | |||||
| * | Use dedicated connection for group coordinator (#1822) | Dana Powers | 2019-06-19 | 1 | -3/+3 |
| | | | | This changes the coordinator_id to be a unique string, e.g., `coordinator-1`, so that it will get a dedicated connection. This won't eliminate lock contention because the client lock applies to all connections, but it should improve in-flight-request contention. | ||||
| * | A little python cleanup (#1805) | Jeff Widman | 2019-05-17 | 1 | -4/+2 |
| | | | | | | | 1. Remove unused variable: `partitions_for_topic` 2. No need to cast to list as `sorted()` already returns a list 3. Using `enumerate()` is cleaner than `range(len())` and handles assigning `member` | ||||
| * | Attempt to join heartbeat thread during close() (#1735) | Dana Powers | 2019-03-13 | 1 | -3/+6 |
| | | | | | | | | Underlying issue here is a race on consumer.close() between the client, the connections/sockets, and the heartbeat thread. Although the heartbeat thread is signaled to close, we do not block for it. So when we go on to close the client and its underlying connections, if the heartbeat is still doing work it can cause errors/crashes if it attempts to access the now closed objects (selectors and/or sockets, primarily). So this commit adds a blocking thread join to the heartbeat close. This may cause some additional blocking time on consumer.close() while the heartbeat thread finishes. But it should be small in average case and in the worst case will be no longer than the heartbeat_timeout_ms (though if we timeout the join, race errors may still occur). Fix #1666 | ||||
| * | Ignore lookup_coordinator result in commit_offsets_async (#1712) | Faqa | 2019-03-12 | 1 | -1/+2 |
| | | |||||
| * | Do network connections and writes in KafkaClient.poll() (#1729) | Dana Powers | 2019-03-08 | 1 | -2/+2 |
| | | | | | | | * Add BrokerConnection.send_pending_requests to support async network sends * Send network requests during KafkaClient.poll() rather than in KafkaClient.send() * Dont acquire lock during KafkaClient.send if node is connected / ready * Move all network connection IO into KafkaClient.poll() | ||||
| * | Improve KafkaConsumer join group / only enable Heartbeat Thread during ↵ | Dana Powers | 2019-01-15 | 1 | -11/+23 |
| | | | | | stable group (#1695) | ||||
| * | Be explicit with tuples for %s formatting | Jeff Widman | 2018-11-18 | 1 | -3/+3 |
| | | | | | Fix #1633 | ||||
| * | (Attempt to) Fix deadlock between consumer and heartbeat (#1628) | Dana Powers | 2018-11-10 | 1 | -1/+1 |
| | | |||||
| * | Return future from commit_offsets_async (#1560) | Mike Lang | 2018-08-31 | 1 | -1/+6 |
| | | |||||
| * | Don't use `kafka.common` internally1.3.5 | Jeff Widman | 2018-06-05 | 2 | -2/+2 |
| | | | | | This finishes the split from `kafka.common` to `kafka.errors`/`kafka.structs`. | ||||
| * | Always acquire client lock before coordinator lock to avoid deadlocks (#1464) | Dana Powers | 2018-04-18 | 1 | -59/+64 |
| | | |||||
| * | Heartbeat thread start / close | Dana Powers | 2018-03-23 | 1 | -2/+4 |
| | | |||||
| * | Change levels for some heartbeat thread logging | Dana Powers | 2018-03-23 | 1 | -3/+3 |
| | | |||||
| * | Check for immediate failure when looking up coordinator in heartbeat thread ↵ | Dana Powers | 2018-03-23 | 1 | -1/+5 |
| | | | | | (#1457) | ||||
| * | KAFKA-5512; Awake the heartbeat thread when timetoNextHeartbeat is equal to ↵ | Dana Powers | 2018-03-10 | 1 | -0/+4 |
| | | | | | 0 (#1439) | ||||
| * | Remove old CommitFailed error message from coordinator (#1436) | Dana Powers | 2018-03-10 | 1 | -11/+1 |
| | | |||||
| * | Fix consumer poll stuck error when no available partition (#1375) | Yu Kou | 2018-02-08 | 1 | -1/+1 |
| | | |||||
| * | use absolute imports everywhere (#1362) | Kevin Tindall | 2018-02-06 | 4 | -23/+23 |
| | | |||||
| * | KAFKA-3949: Avoid race condition when subscription changes during rebalance ↵ | Dana Powers | 2018-02-02 | 2 | -50/+76 |
| | | | | | (#1364) | ||||
| * | Name heartbeat thread with group_id; use backoff when polling (#1345) | Dana Powers | 2018-01-16 | 1 | -1/+1 |
| | | |||||
| * | Fix coordinator join_future race condition (#1338) | Dana Powers | 2018-01-11 | 1 | -4/+8 |
| | | | | * Fix race condition in coordinator join_future handling | ||||
| * | Improve KafkaConsumer cleanup (#1339) | Dana Powers | 2018-01-10 | 2 | -11/+28 |
| | | |||||
| * | KAFKA-3888 Use background thread to process consumer heartbeats (#1266) | Dana Powers | 2017-12-21 | 3 | -350/+615 |
| | | |||||
| * | Replace periods (java) with underscores (python) | Jeff Widman | 2017-11-07 | 1 | -2/+2 |
| | | |||||
| * | Handle lookup_coordinator send failures (#1279) | Dana Powers | 2017-10-24 | 1 | -5/+11 |
| | | |||||
| * | KAFKA-4034: Avoid unnecessary consumer coordinator lookup (#1254) | Dana Powers | 2017-10-11 | 2 | -8/+43 |
| | | |||||
| * | Explicitly check for `None` rather than False | Jeff Widman | 2017-10-06 | 1 | -1/+1 |
| | | | | | | If the group leader somehow gets in a state that it has an empty partition assignment, then `self._assignment_snapshot` will be `{}` which evaluates to `False`. So `self._subscription.mark_for_reassignment()` will never be triggered, even if `self._assignment_snapshot != self._metadata_snapshot`. Fixes the symptoms of https://github.com/dpkp/kafka-python/issues/1237 although I suspect there's an additional bug in that case that triggers the condition of the the group leader getting an empty partition assignment. | ||||
| * | Initialize metadata_snapshot in group coordinator (#1174) | Dana Powers | 2017-08-13 | 1 | -6/+9 |
| | | |||||
| * | Use for join-time-max and sync-time-max metrics Max() measure function (#1146) | Alexey Pervushin | 2017-07-20 | 1 | -2/+2 |
| | | |||||
| * | 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. | ||||
| * | Backoff on unavailable group coordinator retry (#1125) | Dana Powers | 2017-06-19 | 1 | -0/+2 |
| | | |||||
| * | Additional docstrings for autocommit close option | Dana Powers | 2017-03-13 | 2 | -2/+10 |
| | | |||||
| * | Optionally skip auto-commit during consumer.close (#1031) | Dana Powers | 2017-03-13 | 1 | -2/+3 |
| | | |||||
| * | Short-circuit group coordinator requests when NodeNotReady (#995) | Dana Powers | 2017-03-09 | 1 | -0/+23 |
| | | |||||
| * | Avoid unknown coordinator after client poll (#1023) | Dana Powers | 2017-03-09 | 1 | -7/+6 |
| | | |||||
| * | For 0.8.2, only attempt connection to coordinator if least_loaded_node succeeds | Dana Powers | 2017-03-07 | 1 | -1/+2 |
| | | |||||
| * | Minor additional logging for consumer coordinator | Dana Powers | 2017-03-06 | 1 | -0/+2 |
| | | |||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |