summaryrefslogtreecommitdiff
path: root/kafka/producer/sender.py
Commit message (Collapse)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
| | | | | (#1185) Added bytecode optimization for varint and append/read_msg functions. Mostly based on avoiding LOAD_GLOBAL calls.
* Refactor MessageSet and Message into LegacyRecordBatch to later support v2 ↵Taras2017-10-111-1/+0
| | | | message format
* Remove a few unused imports (#1188)James Lamb2017-08-291-1/+1
| | | | | * Removed a few unused imports * Added note on socketpair monkey-path
* 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 python module six; move selectors34 and socketpair under kafka.vendor
| * Vendor six 1.10.0sixDana Powers2016-08-011-1/+1
| |
* | Rename _DEFAULT_CONFIG -> DEFAULT_CONFIG in KafkaProducer (#788)Dana Powers2016-08-011-2/+2
|/ | | - also update internal classes RecordAccumulator and Sender
* 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 ↵Dana Powers2016-05-221-0/+11
| | | | guarantee ordering (#698)
* 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
| | | | messagesets
* 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
View Lorry Controller Status