summaryrefslogtreecommitdiff
path: root/kafka/producer/sender.py
Commit message (Collapse)AuthorAgeFilesLines
* Vendor six 1.10.0sixDana Powers2016-08-011-1/+1
|
* 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