delta/python-packages/kafka-python.git/kafka, branch wake_socketpair_exceptionsgithub.com: mumrah/kafka-python.git
Catch socket.errors when sending / recving bytes on wake socketpair2017-04-05T05:00:37+00:00Dana Powersdana.powers@gmail.com2017-04-05T05:00:37+00:00a4d4a7412ee9aad0197306b43af957200442820c
Fix poll() hyperlink in KafkaClient2017-03-30T00:35:09+00:00Jeff Widmanjeff@jeffwidman.com2017-03-29T21:17:58+00:00d40d106c7327a842ab393fb86d1be0048b0a83ba
Previously Sphinx was auto-linking to `poll()` in `KafkaConsumer`, so made the link explicit.
Previously Sphinx was auto-linking to `poll()` in `KafkaConsumer`, so made the link explicit.
Derive all api classes from Request / Response base classes (#1030)2017-03-14T20:34:37+00:00Dana Powersdana.powers@gmail.com2017-03-14T20:34:37+00:0065ba8822b10e6f8a3ba4e9a6b0a1e6f9b785c18e
LZ4 support in kafka 0.8/0.9 does not accept a ContentSize header2017-03-14T20:30:35+00:00Dana Powersdana.powers@gmail.com2017-03-14T18:01:58+00:00fea10d9c169214af82303744069bdd6c66c4a2ef
Prefer python-lz4 over lz4f if available2017-03-14T20:30:35+00:00Dana Powersdana.powers@gmail.com2017-03-13T21:22:57+00:00fb023fe85d0bac4e088346765311794a574d13bf
Free lz4 decompression context to avoid leak2017-03-14T20:30:35+00:00Dana Powersdana.powers@gmail.com2017-03-09T19:08:48+00:003b899decb8b5159c1086a5211eda315c090c6d59
Avoid re-encoding for message crc check (#1027)2017-03-13T23:41:38+00:00Dana Powersdana.powers@gmail.com2017-03-13T23:41:38+00:0047004bbd026fc9267f5cf15b96bb4b2d2bb1dc78