delta/python-packages/kafka-python.git/kafka, branch message_format_v1 github.com: mumrah/kafka-python.git KAFKA-3025: Message v1 -- add timetamp and use relative offset in compressed messagesets 2016-05-22T16:51:37+00:00 Dana Powers dana.powers@gmail.com 2016-05-22T07:31:16+00:00 795cb9b29fa05d4425f807f54dfa639c125fc0dd 






Always pass encoded message bytes to MessageSet.encode()
2016-05-22T07:17:51+00:00

Dana Powers
dana.powers@gmail.com

2016-05-22T04:43:44+00:00

7f4a9361ea168a0e1073801d0b86868de47d1de2












raise ValueError on protocol encode/decode errors
2016-05-22T07:17:51+00:00

Dana Powers
dana.powers@gmail.com

2016-05-22T04:25:55+00:00

f2991be6143c6a1a79815ea20fe95bae8f5376ac












Add CRL support to SSL support (#683)
2016-05-19T14:19:34+00:00

Vincent Bernat
vincent@bernat.im

2016-05-19T14:19:34+00:00

92f859d8da5c3f35ab3738ef2725fff05b6cf57f

A user can provide a CRL whose peer certificate will be checked
against. This only works with Python 3.4+ and Python 2.7.9+.




A user can provide a CRL whose peer certificate will be checked
against. This only works with Python 3.4+ and Python 2.7.9+.






Fixup BrokerConnection check_version strict error checking: 0.9 will fail with CorrelationIdError
2016-05-17T14:24:00+00:00

Dana Powers
dana.powers@gmail.com

2016-05-17T14:23:37+00:00

254dcacb28f66c8426fb8ff161b88e2feb4c486a












supplement socket.gaierror exception in BrokerConnection.connect() (#687)
2016-05-17T14:04:05+00:00

Erik Beebe
erik@beebe.cc

2016-05-17T14:04:05+00:00

d7fa0731a0aba7cb59addbbc9f6f3b270a842df7

supplement socket.gaierror exception to include the host/port




supplement socket.gaierror exception to include the host/port






kafka/conn: use original hostname for SSL checks (#682)
2016-05-17T13:55:12+00:00

Vincent Bernat
vincent@bernat.im

2016-05-17T13:55:12+00:00

a7e9dfc405d5d1de60ce15bc6dad016d6418e3aa

When the address family is not provided, `self.host` is resolved to one
of the IP addresses and replaced by it. The SSL context is then built
using `self.host` which is now an IP instead of the proper name. Most of
the time, hostname cannot be checked this way. Therefore, save the
original hostname in a dedicated property and use this property for the
SSL context.




When the address family is not provided, `self.host` is resolved to one
of the IP addresses and replaced by it. The SSL context is then built
using `self.host` which is now an IP instead of the proper name. Most of
the time, hostname cannot be checked this way. Therefore, save the
original hostname in a dedicated property and use this property for the
SSL context.






* [SimpleConsumer] Fix legacy SimpleConsumer when using compressed messages* [Legacy Protocol] Update legacy protocol to handle compressed messages
2016-05-10T15:34:06+00:00

Paul Cavallaro
paulcavallaro@users.noreply.github.com

2016-05-10T15:34:06+00:00

2c9930dea4a4537cf237ac7cc9db1f3970419b59

* [SimpleConsumer] Fix legacy SimpleConsumer when using compressed messages




* [SimpleConsumer] Fix legacy SimpleConsumer when using compressed messages






Merge pull request #679 from zackdever/kafka-PR-1265-bugfix
2016-05-04T01:21:14+00:00

Zack Dever
zackdever@gmail.com

2016-05-04T01:21:14+00:00

0684302d8fa1271ad0e913972b382b00ddeab717

small bug fix in Sensor




small bug fix in Sensor






small bug fix in Sensor
2016-05-04T00:43:50+00:00

Zack Dever
zackdever@gmail.com

2016-05-04T00:43:50+00:00

416f50b6f78328878e950d7bd8dd902c52d35b13

pulling in this small bug fix from https://github.com/apache/kafka/pull/1265/files#diff-8736b7fd8ad077ea55ea2a8ad61285faR99




pulling in this small bug fix from https://github.com/apache/kafka/pull/1265/files#diff-8736b7fd8ad077ea55ea2a8ad61285faR99