summaryrefslogtreecommitdiff
path: root/kafka/producer/sender.py
Commit message (Expand)AuthorAgeFilesLines
* use python standard max value (#1303)lukeWx2017-12-071-1/+1
* Add DefaultRecordBatch implementation aka V2 message format parser/builder. (...Taras Voinarovskyi2017-10-251-2/+7
* Refactor MessageSet and Message into LegacyRecordBatch to later support v2 me...Taras2017-10-111-1/+0
* Remove a few unused imports (#1188)James Lamb2017-08-291-1/+1
* Drop unused sleep kwarg to poll (#1177)Dana Powers2017-08-151-1/+1
* Instrument metrics in BrokerConnectionDana Powers2016-08-041-17/+0
* Merge pull request #785 from dpkp/sixDana Powers2016-08-011-1/+1
|\
| * Vendor six 1.10.0sixDana Powers2016-08-011-1/+1
* | Rename _DEFAULT_CONFIG -> DEFAULT_CONFIG in KafkaProducer (#788)Dana Powers2016-08-011-2/+2
|/
* Record produce latency and throttling metricsDana Powers2016-07-171-4/+9
* Add initial producer-sender metricsDana Powers2016-07-161-3/+209
* Wakeup socket optimizations (#740)Dana Powers2016-06-261-1/+6
* KAFKA-3197: when max.in.flight.request.per.connection = 1, attempt to guarant...Dana Powers2016-05-221-0/+11
* Use Fetch/Produce API v2 for brokers >= 0.10 (uses message format v1) (#694)Dana Powers2016-05-221-3/+13
* KAFKA-3025: Message v1 -- add timetamp and use relative offset in compressed ...Dana Powers2016-05-221-4/+5
* KAFKA-2136: support Fetch and Produce v1 (throttle_time_ms)kafka-2136Dana Powers2016-04-061-3/+5
* Use version-indexed lists for request/response protocol structsprotocol_versionsDana Powers2016-04-051-3/+1
* Update imports from kafka.common -> kafka.errors / kafka.structsDana Powers2016-04-051-2/+2
* remove unused import. needed a change to kick travis.Zack Dever2016-03-141-1/+0
* make Sender._topics_to_add a set instead of a listZack Dever2016-03-141-3/+4
* Remove unused internal sender lockDana Powers2016-02-151-21/+18
* Add more debug/trace statements to sender loopDana Powers2016-02-021-0/+2
* Sender class to manage background IO for KafkaProducerDana Powers2016-01-241-0/+272