| Commit message (Collapse) | Author | Age | Files | Lines | ||
|---|---|---|---|---|---|---|
| ... | ||||||
| * | * [SimpleConsumer] Fix legacy SimpleConsumer when using compressed messages* ↵ | Paul Cavallaro | 2016-05-10 | 2 | -3/+30 | |
| | | | | | | [Legacy Protocol] Update legacy protocol to handle compressed messages * [SimpleConsumer] Fix legacy SimpleConsumer when using compressed messages | |||||
| * | Merge pull request #679 from zackdever/kafka-PR-1265-bugfix | Zack Dever | 2016-05-03 | 1 | -1/+1 | |
| |\ | | | | | small bug fix in Sensor | |||||
| | * | small bug fix in Sensor | Zack Dever | 2016-05-03 | 1 | -1/+1 | |
| | | | | | | | pulling in this small bug fix from https://github.com/apache/kafka/pull/1265/files#diff-8736b7fd8ad077ea55ea2a8ad61285faR99 | |||||
| * | | Merge pull request #678 from dpkp/check_version_0_10 | Dana Powers | 2016-05-03 | 4 | -3/+26 | |
| |\ \ | |/ |/| | Add protocol support for ApiVersionRequest | |||||
| | * | Add protocol support for ApiVersionRequest; identify 0.10 brokers in ↵check_version_0_10 | Dana Powers | 2016-05-02 | 4 | -3/+26 | |
| |/ | | | | check_version | |||||
| * | Patch release: 1.1.11.1.1 | Dana Powers | 2016-04-25 | 3 | -1/+23 | |
| | | ||||||
| * | Merge pull request #671 from dpkp/disconnects | Dana Powers | 2016-04-25 | 3 | -24/+87 | |
| |\ | | | | | Improve socket disconnect handling | |||||
| | * | Improve socket disconnect handlingdisconnects | Dana Powers | 2016-04-25 | 2 | -5/+23 | |
| | | | ||||||
| | * | 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 | |
| | | | ||||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |