Code

KafkaProducer#515

Code

Merged

dpkp merged 14 commits intomasterdpkp/kafka-python:masterfrom

kafka_producerdpkp/kafka-python:kafka_producerCopy head branch name to clipboard

Jan 25, 2016

Commits

Commits on Jan 24, 2016

• Add Message and MessageSet HEADER_SIZE bytes

  

  Dana Powers

  committed
  ee19cbf

  Copy full SHA for ee19cbf

• Support encode and repr on raw BytesIO MessageSets (used in new producer)

  

  Dana Powers

  committed
  da78721

  Copy full SHA for da78721

• DefaultPartitioner - implements java client logic

  

  Dana Powers

  committed
  030d133

  Copy full SHA for 030d133

Commits on Jan 25, 2016

• Add MessageSetBuffer and SimpleBufferPool to manage producer messages

  

  Dana Powers

  committed
  f944392

  Copy full SHA for f944392

• Add thread-aware futures for use with KafkaProducer

  

  Dana Powers

  committed
  4761e24

  Copy full SHA for 4761e24

• RecordAccumulator and RecordBatch, for use by async batching KafkaProducer

  

  Dana Powers

  committed
  a250fe3

  Copy full SHA for a250fe3

• Sender class to manage background IO for KafkaProducer

  

  Dana Powers

  committed
  434d1ab

  Copy full SHA for 434d1ab

• Implement new KafkaProducer, mimicing java client interface / design

  

  Dana Powers

  committed
  44330f4

  Copy full SHA for 44330f4

• Add KafkaProducer to kafka and kafka.producer module imports

  

  Dana Powers

  committed
  0a6af29

  Copy full SHA for 0a6af29

• Rename legacy producer tests

  

  Dana Powers

  committed
  34a18ae

  Copy full SHA for 34a18ae

• Move pytest broker/zk fixtures to test.conftest

  

  Dana Powers

  committed
  acd1ae4

  Copy full SHA for acd1ae4

• add DefaultPartitioner test

  

  Dana Powers

  committed
  4d993bb

  Copy full SHA for 4d993bb

• Add simple KafkaProducer -> KafkaConsumer integration test

  

  Dana Powers

  committed
  f516231

  Copy full SHA for f516231

• Add KafkaProducer to autodocs and README

  

  Dana Powers

  committed
  85c0dd2

  Copy full SHA for 85c0dd2