delta/python-packages/kafka-python.git/kafka/protocol, branch conn_send_timeoutgithub.com: mumrah/kafka-python.git
Added limit of 100 bytes for Bytes debug prints2017-10-14T09:59:09+00:00Taras Voinarovskiyvoyn1991@gmail.com2017-10-14T09:59:09+00:00365cae02da59721df77923bb5f5a2d94a84b2e83
Added minor fixes for PR review2017-10-12T08:10:44+00:00Tarasvoyn1991@gmail.com2017-10-12T08:07:14+00:00d10051bb09942bfd48c6f262a8cdbf5651963c2e
Refactor MessageSet and Message into LegacyRecordBatch to later support v2 message format2017-10-11T15:09:17+00:00Tarasvoyn1991@gmail.com2017-10-09T21:13:16+00:00fbea5f04bccd28f3aa15a1711548b131504591ac
Add kafka.protocol.parser.KafkaProtocol w/ receive and send (#1230)2017-10-10T17:15:40+00:00Dana Powersdana.powers@gmail.com2017-10-10T17:15:40+00:000d4e28f05efd2a1e39558ab2516e054b97297900
Added basic support for offsets_for_times API. Still needs to group by nodes and send in parallel.2017-08-07T09:34:08+00:00Taras Voinarovskiyvoyn1991@gmail.com2017-07-30T15:42:27+00:0039f0e50b9441609e9dce4e60a1ab2c3f16680476
Add private map of api key -> min/max versions to BrokerConnection (#1169)2017-08-07T00:41:13+00:00Dana Powersdana.powers@gmail.com2017-08-07T00:41:13+00:00da25df6d3c6380e27bf638f3620613d05ac9fd03
Protocol updates for 0.11.0.0 (#1127)2017-07-09T15:04:39+00:00Dana Powersdana.powers@gmail.com2017-07-09T15:04:39+00:00d0c6b1f95c2e677545d1faaeae525e8768abea9e
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
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