Add flush to close method

wahani · wahani · commit 695a43b5bc73 · 2023-12-15T14:12:47.000+01:00
diff --git a/src/producer.cpp b/src/producer.cpp
@@ -61,6 +61,10 @@ class Producer
 
     void close()
     {
+        // Following
+        // https://github.com/confluentinc/librdkafka/blob/master/INTRODUCTION.md#producer
+        // and https://github.com/confluentinc/librdkafka/issues/1499
+        producer->flush(60*1000);
         delete producer;
     }
 

Original file line number	Diff line number	Diff line change
`@@ -61,6 +61,10 @@ class Producer`
`61`	`61`
`62`	`62`	`void close()`
`63`	`63`	`{`
	`64`	`+ // Following`
	`65`	`+ // https://github.com/confluentinc/librdkafka/blob/master/INTRODUCTION.md#producer`
	`66`	`+ // and https://github.com/confluentinc/librdkafka/issues/1499`
	`67`	`+ producer->flush(60*1000);`
`64`	`68`	`delete producer;`
`65`	`69`	`}`
`66`	`70`