Code

Add flush method to AIOKafkaProducer#209

Code

Merged

tvoinarovskyi merged 4 commits intoaio-libs:masteraio-libs/aiokafka:masterfrom vineetgoel:mastervineetgoel/aiokafka:masterCopy head branch name to clipboardAug 28, 2017

+11-3

Commits

Commits on Aug 22, 2017

• Add producer.flush

  

  Vineet Goel

  committed
  7fe0d72

  Copy full SHA for 7fe0d72

• Adding flushing logic to MessageAccumulator

  

  Vineet Goel

  committed
  8bb6e24

  Copy full SHA for 8bb6e24

• Set accumulator state to closed while flushing to avoid adding messages

  

  Vineet Goel

  committed
  098d024

  Copy full SHA for 098d024

Commits on Aug 28, 2017

• Do not close producer while flushing

  

  Vineet Goel

  committed
  485351d

  Copy full SHA for 485351d