| Commit message (Collapse) | Author | Age | Files | Lines | ||
|---|---|---|---|---|---|---|
| ... | ||||||
| | * | Disable standard metadata refresh hook during bootstrap | Dana Powers | 2016-04-25 | 1 | -0/+2 | |
| | | | ||||||
| | * | Add disconnected socket tests for conn.recv() | Dana Powers | 2016-04-25 | 1 | -1/+46 | |
| | | | ||||||
| | * | Rename mocked socket as _socket in test_conn | Dana Powers | 2016-04-25 | 1 | -18/+16 | |
| |/ | ||||||
| * | handle unexpected reads in client_async | James Brown | 2016-04-25 | 1 | -0/+19 | |
| | | | | | Should fix #661. | |||||
| * | Merge pull request #670 from zackdever/predictable-future | Dana Powers | 2016-04-25 | 3 | -13/+19 | |
| |\ | | | | | Consistent error handling in future call/errbacks + better test failures | |||||
| | * | enable errors on callbacks in testing. fix broken test. | Zack Dever | 2016-04-25 | 2 | -1/+4 | |
| | | | ||||||
| | * | use the same logic for callbacks regardless of is_done status | Zack Dever | 2016-04-25 | 1 | -12/+15 | |
| | | | ||||||
| * | | Allow setting host interface in KafkaFixture.instance | Dana Powers | 2016-04-25 | 1 | -2/+4 | |
| |/ | ||||||
| * | Fix throttle_time_ms sensor | Zack Dever | 2016-04-25 | 1 | -1/+2 | |
| | | | | Fixes #665 | |||||
| * | Build universal wheels - kafka-python is compatible with both py2 and py3 | Dana Powers | 2016-04-25 | 1 | -0/+2 | |
| | | ||||||
| * | Avoid some exceptions in Coordinator.__del__ (#668) | Dana Powers | 2016-04-25 | 2 | -2/+4 | |
| | | ||||||
| * | Bump version for development | Dana Powers | 2016-04-25 | 1 | -1/+1 | |
| | | ||||||
| * | Fix hyperlinks in README to fix pypi rendering1.1.0 | Dana Powers | 2016-04-24 | 1 | -5/+5 | |
| | | ||||||
| * | Release 1.1.0 | Dana Powers | 2016-04-24 | 1 | -1/+1 | |
| | | ||||||
| * | Update changelogs for 1.1.0 release | Dana Powers | 2016-04-24 | 2 | -0/+84 | |
| | | ||||||
| * | Merge branch 'EasyPost-better_ipv6' | Dana Powers | 2016-04-24 | 5 | -43/+137 | |
| |\ | ||||||
| | * | More thorough IPv6 support that uses getaddrinfo to resolve names | James Brown | 2016-04-24 | 5 | -43/+137 | |
| |/ | | | | Fixes #641 | |||||
| * | Wait for future.is_done in check_version (fix for windows) | Dana Powers | 2016-04-24 | 1 | -5/+5 | |
| | | ||||||
| * | Merge pull request #649 from jayalane/master | Dana Powers | 2016-04-24 | 1 | -2/+4 | |
| |\ | | | | | to squelch the __del issue | |||||
| | * | as per code review | Chris Lane | 2016-04-14 | 1 | -2/+2 | |
| | | | ||||||
| | * | to squelch the __del issue | Chris Lane | 2016-04-13 | 1 | -2/+4 | |
| | | | ||||||
| * | | Merge pull request #637 from zackdever/metrics | Zack Dever | 2016-04-14 | 32 | -121/+1994 | |
| |\ \ | |/ |/| | Metrics java port | |||||
| | * | instrument metrics for fetch requests | Zack Dever | 2016-04-13 | 3 | -66/+95 | |
| | | | ||||||
| | * | trying to use locks a little less. still not ideal. | Zack Dever | 2016-04-13 | 4 | -19/+18 | |
| | | | ||||||
| | * | Changing some commented out metrics to avoid future gotchas. | Zack Dever | 2016-04-13 | 2 | -4/+4 | |
| | | | ||||||
| | * | Beginnings of metrics instrumentation in kafka consumer. | Zack Dever | 2016-04-13 | 3 | -53/+66 | |
| | | | | | | | | | | | | | This adds the parent metrics instance to kafka consumer, which will eventually be used to instrument everything under consumer. To start I ported the java consumer coordinator metrics. | |||||
| | * | Basic dictionary reporter in place of the java JMX reporter. | Zack Dever | 2016-04-13 | 3 | -4/+120 | |
| | | | ||||||
| | * | Kafka metrics java port. No reporters or instrumentation. | Zack Dever | 2016-04-13 | 25 | -0/+1716 | |
| |/ | | | | | There is no straight translation for the JMX reporter into python, so I'll do something else in a separate commit. | |||||
| * | Merge pull request #621 from dpkp/ssl_support | Dana Powers | 2016-04-09 | 10 | -16/+216 | |
| |\ | | | | | Support SSL connections | |||||
| | * | Attempt to add ssl support to kafka fixturesssl_support | Dana Powers | 2016-04-09 | 5 | -10/+44 | |
| | | | ||||||
| | * | Add SSL configuration kwargs to KafkaClient, KafkaConsumer, KafkaProducer | Dana Powers | 2016-04-09 | 3 | -0/+63 | |
| | | | ||||||
| | * | Check for pending ssl bytes in KafkaClient loop | Dana Powers | 2016-04-09 | 1 | -0/+12 | |
| | | | ||||||
| | * | Update conn fixture to check for HANDSHAKE state | Dana Powers | 2016-04-09 | 1 | -1/+2 | |
| | | | ||||||
| | * | Handle SSL HANDSHAKE state in KafkaClient state change handler | Dana Powers | 2016-04-09 | 1 | -2/+4 | |
| | | | ||||||
| | * | Add ssl support to BrokerConnection | Dana Powers | 2016-04-09 | 1 | -3/+91 | |
| |/ | ||||||
| * | Merge pull request #640 from dpkp/selectors | Dana Powers | 2016-04-09 | 3 | -33/+682 | |
| |\ | | | | | Manage non-blocking I/O events with selectors module | |||||
| | * | Use selectors module in KafkaClientselectors | Dana Powers | 2016-04-09 | 2 | -33/+47 | |
| | | | ||||||
| | * | Vendor selectors34 module | Dana Powers | 2016-04-08 | 1 | -0/+635 | |
| |/ | ||||||
| * | Merge pull request #639 from dpkp/conn_state_callback | Dana Powers | 2016-04-08 | 3 | -110/+174 | |
| |\ | | | | | Use KafkaClient callback to manage BrokerConnection state changes | |||||
| | * | Add state_change_callback to bootstrap connectionconn_state_callback | Dana Powers | 2016-04-08 | 2 | -3/+12 | |
| | | | ||||||
| | * | Drop bootstrap connection once first normal broker is connected | Dana Powers | 2016-04-08 | 1 | -0/+6 | |
| | | | ||||||
| | * | Add private _refresh_on_disconnects flag to KafkaClient | Dana Powers | 2016-04-08 | 1 | -2/+8 | |
| | | | ||||||
| | * | Move state logic from KafkaClient._maybe_connect to _conn_state_change as ↵ | Dana Powers | 2016-04-08 | 2 | -29/+43 | |
| | | | | | | | | | callback | |||||
| | * | Add state_change_callback to BrokerConnection | Dana Powers | 2016-04-08 | 1 | -0/+8 | |
| | | | ||||||
| | * | Move check_version() logic to BrokerConnection | Dana Powers | 2016-04-08 | 2 | -78/+99 | |
| |/ | ||||||
| * | Split test_ready to test_is_ready | Dana Powers | 2016-04-08 | 1 | -34/+21 | |
| | | ||||||
| * | Speedup some failover tests w/ shorter SimpleClient timeout | Dana Powers | 2016-04-08 | 1 | -1/+1 | |
| | | ||||||
| * | Reduce batch time in producer integration test (speedup test) | Dana Powers | 2016-04-08 | 1 | -2/+5 | |
| | | ||||||
| * | Default sleep=True in client.poll | Dana Powers | 2016-04-08 | 4 | -7/+7 | |
| | | ||||||
| * | Make _wake_r socket non-blocking; drop select from _clear_wake_fd | Dana Powers | 2016-04-08 | 1 | -3/+4 | |
| | | ||||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |