| Commit message (Collapse) | Author | Age | Files | Lines | ||
|---|---|---|---|---|---|---|
| ... | ||||||
| * | Use python3 compatible next() in roundrobin assignor | Dana Powers | 2016-01-01 | 1 | -2/+2 | |
| | | ||||||
| * | sys.maxint not supported in python3 | Dana Powers | 2016-01-01 | 1 | -4/+3 | |
| | | ||||||
| * | Use pytest instead of nose for running tests via tox | Dana Powers | 2016-01-01 | 4 | -54/+12 | |
| | | | | | | | | - use pytest-sugar for pretty output - add linting to each python tox environment - drop lint as separate tox target - replace travis_selector.sh with shell magic | |||||
| * | Use find_packages() for setup.py | Dana Powers | 2016-01-01 | 1 | -9/+2 | |
| | | ||||||
| * | Skeleton tests for async kafka client | Dana Powers | 2016-01-01 | 1 | -0/+103 | |
| | | ||||||
| * | Struct __eq__ | Dana Powers | 2016-01-01 | 1 | -0/+7 | |
| | | ||||||
| * | Remove some unused bits from kafka.consumer.group | Dana Powers | 2015-12-31 | 1 | -5/+0 | |
| | | ||||||
| * | Improve request pipelining in consumer iterator | Dana Powers | 2015-12-31 | 2 | -13/+28 | |
| | | ||||||
| * | Fixup heartbeat config assertion | Dana Powers | 2015-12-31 | 1 | -1/+1 | |
| | | ||||||
| * | Support message decompression | Dana Powers | 2015-12-31 | 2 | -21/+40 | |
| | | ||||||
| * | Towards version 1.0 | Dana Powers | 2015-12-30 | 1 | -1/+1 | |
| | | ||||||
| * | Support simple message iteration in Fetcher and new KafkaConsumer | Dana Powers | 2015-12-30 | 2 | -0/+71 | |
| | | ||||||
| * | Rename AbstractCoordinator -> BaseCoordinator, log as kafka.coordinator | Dana Powers | 2015-12-30 | 2 | -5/+5 | |
| | | ||||||
| * | Prefer assert or more-specific error to IllegalState / IllegalArgument | Dana Powers | 2015-12-30 | 9 | -69/+36 | |
| | | ||||||
| * | Catch GroupCoordinatorNotAvailableError in GroupCoordinatorResponse handler | Dana Powers | 2015-12-30 | 1 | -0/+3 | |
| | | ||||||
| * | Start test fixtures in new session to avoid propagating signals (i.e., Ctrl-C) | Dana Powers | 2015-12-30 | 1 | -0/+2 | |
| | | ||||||
| * | More Docstring Improvements | Dana Powers | 2015-12-30 | 7 | -152/+431 | |
| | | ||||||
| * | Fix blacked_out typo in least_loaded_node | Dana Powers | 2015-12-30 | 1 | -1/+1 | |
| | | ||||||
| * | BrokerConnection: wrap socket errors in retriable ConnectionError | Dana Powers | 2015-12-30 | 1 | -3/+3 | |
| | | ||||||
| * | Rename KafkaClient.connection_failed -> is_disconnected | Dana Powers | 2015-12-30 | 2 | -2/+2 | |
| | | ||||||
| * | Drop unused KafkaConsumer._ensure_not_closed method | Dana Powers | 2015-12-30 | 1 | -4/+0 | |
| | | ||||||
| * | Make group_id a Coordinator kwarg (not arg) for consistency | Dana Powers | 2015-12-30 | 3 | -8/+6 | |
| | | ||||||
| * | Improve removed tasks handing in DelayedTaskQueue.pop_ready | Dana Powers | 2015-12-30 | 1 | -2/+5 | |
| | | ||||||
| * | Remove unnecessary calls in KafkaClient._poll | Dana Powers | 2015-12-30 | 1 | -13/+13 | |
| | | | | | | - Dont process connections; outer poll() loop does this now - Only recv connections that select says are readable | |||||
| * | Resolve delayed task futures in KafkaClient.poll | Dana Powers | 2015-12-30 | 1 | -3/+6 | |
| | | ||||||
| * | Remove unused connection_delay method from KafkaClient | Dana Powers | 2015-12-30 | 1 | -18/+0 | |
| | | ||||||
| * | Switch configs from attributes to dict to make passing / inspecting easier | Dana Powers | 2015-12-29 | 8 | -211/+211 | |
| | | ||||||
| * | Use _next_correlation_id() method to avoid int overflows | Dana Powers | 2015-12-29 | 1 | -4/+8 | |
| | | ||||||
| * | Fix log statement bug (via pylint) | Dana Powers | 2015-12-29 | 1 | -1/+1 | |
| | | ||||||
| * | Clean more ConsumerCoordinator docstrings | Dana Powers | 2015-12-29 | 1 | -16/+19 | |
| | | ||||||
| * | Catch and retry on RequestTimedOutError in producer failover test | Dana Powers | 2015-12-29 | 1 | -2/+4 | |
| | | ||||||
| * | Use ConnectionError rather than new DisconnectError | Dana Powers | 2015-12-29 | 2 | -8/+4 | |
| | | ||||||
| * | Dont warn in AutoCommitTask.disable if not previously scheduled | Dana Powers | 2015-12-29 | 1 | -1/+1 | |
| | | ||||||
| * | Improve OffsetCommit error logging | Dana Powers | 2015-12-29 | 1 | -23/+33 | |
| | | | | | | | Avoid printing full errors because they currently include long descriptions that are generally duplicative of our local error message. | |||||
| * | Log request failures in AbstractCoordinator._failed_request | Dana Powers | 2015-12-29 | 1 | -5/+10 | |
| | | ||||||
| * | _handle_group_coordinator_response should resolve future with the coordinator id | Dana Powers | 2015-12-29 | 1 | -1/+1 | |
| | | ||||||
| * | Improve heartbeat logging | Dana Powers | 2015-12-29 | 1 | -14/+13 | |
| | | ||||||
| * | Log as INFO: group join, leader election, partition assignments | Dana Powers | 2015-12-29 | 2 | -1/+5 | |
| | | ||||||
| * | Improve various docstrings | Dana Powers | 2015-12-29 | 3 | -22/+43 | |
| | | ||||||
| * | Remove extra raise and old TODO comment in coordinators | Dana Powers | 2015-12-29 | 2 | -2/+1 | |
| | | ||||||
| * | Make add_assigned_partition private(ish) in SubscriptionState | Dana Powers | 2015-12-29 | 1 | -3/+3 | |
| | | ||||||
| * | Make more methods private(ish) in AbstractCoordinator | Dana Powers | 2015-12-29 | 1 | -13/+13 | |
| | | ||||||
| * | Remove recursive client.poll call in ConsumerCoordinator | Dana Powers | 2015-12-29 | 1 | -2/+3 | |
| | | ||||||
| * | Pass auto commit parameters from KafkaConsumer to ConsumerCoordinator | Dana Powers | 2015-12-29 | 2 | -1/+3 | |
| | | ||||||
| * | Fix broken SubscriptionState.is_assigned call | Dana Powers | 2015-12-29 | 1 | -1/+1 | |
| | | ||||||
| * | Fix HeartbeatTask request_in_flight handling | Dana Powers | 2015-12-29 | 1 | -1/+1 | |
| | | ||||||
| * | kafka.consumer.group.KafkaConsumer: 0.9 coordinator-aware consumer | Dana Powers | 2015-12-28 | 1 | -797/+480 | |
| | | | | | | | | - use ConsumerCoordinator to manage group membership - dynamically assign partitions via group using topic subscription - use upstream configuration parameters as __init__ kwargs - metrics and SSL are still TODO | |||||
| * | ConsumerCoordinator (based on upstream Java client) | Dana Powers | 2015-12-28 | 4 | -0/+703 | |
| | | | | | | | - Use RoundRobinPartitionAssignor by default - Define AbstractPartitionAssignor for custom assignors - metrics still TODO | |||||
| * | AbstractCoordinator (modelled after upstream Java class) | Dana Powers | 2015-12-28 | 4 | -0/+690 | |
| | | | | | | - Heartbeat class manages HeartbeatRequest / Response state - metrics are still TODO | |||||
| * | Define ConsumerRebalanceListener abstract class | Dana Powers | 2015-12-28 | 1 | -0/+84 | |
| | | ||||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |