From a16e46fbd25456abef25e03391c52f10a9fa5161 Mon Sep 17 00:00:00 2001
From: Nick <nickjobszh@gmail.com>
Date: Sun, 3 Jan 2021 19:57:40 +0100
Subject: [PATCH 1/2] update producer example

---
 README.md | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/README.md b/README.md
index 00495d7..1b29725 100644
--- a/README.md
+++ b/README.md
@@ -111,6 +111,9 @@ $message = KafkaProducerMessage::create('test-topic', 0)
             ->withHeaders([ 'key' => 'value' ]);
 
 $producer->produce($message);
+
+// Shutdown producer, flush messages that are in queue. Give up after 20s
+$result = $producer->flush(20000);
 ```
 
 **NOTE:** To improve producer latency you can install the `pcntl` extension.  

From d577fc7d6a80f5ee279d048ab2e297b023881420 Mon Sep 17 00:00:00 2001
From: Nick <nickjobszh@gmail.com>
Date: Sun, 3 Jan 2021 19:59:27 +0100
Subject: [PATCH 2/2] Update README.md

---
 README.md | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/README.md b/README.md
index 1b29725..2c90660 100644
--- a/README.md
+++ b/README.md
@@ -52,6 +52,9 @@ $message = KafkaProducerMessage::create('test-topic', 0)
             ->withHeaders([ 'key' => 'value' ]);
 
 $producer->produce($message);
+
+// Shutdown producer, flush messages that are in queue. Give up after 20s
+$result = $producer->flush(20000);
 ```
 ##### Avro Producer
 To create an avro prodcuer add the avro encoder.