[solr-sandbox] branch crossdc-wip updated: Flush producer on close to prevent losing any pending updates. (#38)

[markrmiller]

This is an automated email from the ASF dual-hosted git repository.

markrmiller pushed a commit to branch crossdc-wip
in repository https://gitbox.apache.org/repos/asf/solr-sandbox.git


The following commit(s) were added to refs/heads/crossdc-wip by this push:
     new 2302dc6  Flush producer on close to prevent losing any pending 
updates. (#38)
2302dc6 is described below

commit 2302dc68c93938bbb0a4de9b671c8beccc808d73
Author: Mark Robert Miller <markrmil...@apache.org>
AuthorDate: Wed Sep 14 17:30:59 2022 -0500

    Flush producer on close to prevent losing any pending updates. (#38)
---
 .../src/main/java/org/apache/solr/crossdc/common/KafkaMirroringSink.java | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/crossdc-commons/src/main/java/org/apache/solr/crossdc/common/KafkaMirroringSink.java
 
b/crossdc-commons/src/main/java/org/apache/solr/crossdc/common/KafkaMirroringSink.java
index 9cfa67f..a1cd2a0 100644
--- 
a/crossdc-commons/src/main/java/org/apache/solr/crossdc/common/KafkaMirroringSink.java
+++ 
b/crossdc-commons/src/main/java/org/apache/solr/crossdc/common/KafkaMirroringSink.java
@@ -138,6 +138,7 @@ public class KafkaMirroringSink implements 
RequestMirroringSink, Closeable {
 
     @Override public void close() throws IOException {
         if (producer != null) {
+            producer.flush();
             producer.close();
         }
     }