Skip to content

Commit 38abb60

Browse files
authored
update producer example (#50)
* update producer example * Update README.md
1 parent 993e9b9 commit 38abb60

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

README.md

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -52,6 +52,9 @@ $message = KafkaProducerMessage::create('test-topic', 0)
5252
->withHeaders([ 'key' => 'value' ]);
5353

5454
$producer->produce($message);
55+
56+
// Shutdown producer, flush messages that are in queue. Give up after 20s
57+
$result = $producer->flush(20000);
5558
```
5659
##### Avro Producer
5760
To create an avro prodcuer add the avro encoder.
@@ -111,6 +114,9 @@ $message = KafkaProducerMessage::create('test-topic', 0)
111114
->withHeaders([ 'key' => 'value' ]);
112115

113116
$producer->produce($message);
117+
118+
// Shutdown producer, flush messages that are in queue. Give up after 20s
119+
$result = $producer->flush(20000);
114120
```
115121

116122
**NOTE:** To improve producer latency you can install the `pcntl` extension.

0 commit comments

Comments
 (0)