delta/python-packages/kafka-python.git/kafka, branch lz4

delta/python-packages/kafka-python.git/kafka, branch lz4 github.com: mumrah/kafka-python.git Add support for LZ4 compressed messages using python-lz4 module 2016-01-25T18:09:15+00:00 Dana Powers dana.powers@rd.io 2016-01-25T06:01:09+00:00 0d5899020a75e22fec14d3e3d7aec8f043d60a31

Disable offset commits and auto-partition-assignment when group_id is None 2016-01-25T02:38:26+00:00 Dana Powers dana.powers@rd.io 2016-01-25T00:22:14+00:00 2a1970138c233e1ebaa58b6db670b2ed0f8d8551

Add KafkaProducer to kafka and kafka.producer module imports 2016-01-25T01:33:09+00:00 Dana Powers dana.powers@rd.io 2016-01-24T06:39:39+00:00 0a6af29625d8266858868112b21f9d00294046e7

Implement new KafkaProducer, mimicing java client interface / design 2016-01-25T01:33:08+00:00 Dana Powers dana.powers@rd.io 2016-01-24T00:58:09+00:00 44330f49cf15d2d22d7e382b52a0727deb246cd6

Sender class to manage background IO for KafkaProducer 2016-01-25T01:33:08+00:00 Dana Powers dana.powers@rd.io 2016-01-23T23:45:29+00:00 434d1abb18a130f54682662909a891edcdb98f5f

RecordAccumulator and RecordBatch, for use by async batching KafkaProducer 2016-01-25T01:33:08+00:00 Dana Powers dana.powers@rd.io 2016-01-23T23:41:44+00:00 a250fe3418a56d0f72458c54078203ee0a65ef0e

Add thread-aware futures for use with KafkaProducer 2016-01-25T01:33:08+00:00 Dana Powers dana.powers@rd.io 2016-01-23T23:34:50+00:00 4761e242c16d184414602296feba4afe8040d14f

Add MessageSetBuffer and SimpleBufferPool to manage producer messages 2016-01-25T01:33:00+00:00 Dana Powers dana.powers@rd.io 2016-01-23T23:32:08+00:00 f944392273baa6c28db82a76b1197fb498737275

DefaultPartitioner - implements java client logic 2016-01-24T21:26:42+00:00 Dana Powers dana.powers@rd.io 2016-01-23T23:27:11+00:00 030d133f6f3e45a6eb2dabf70e4ebe2961f67824

Support encode and repr on raw BytesIO MessageSets (used in new producer) 2016-01-24T21:26:42+00:00 Dana Powers dana.powers@rd.io 2016-01-23T23:25:05+00:00 da787214e1d196992aecf269c9d0105e4c934a4d