You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@solr.apache.org by ma...@apache.org on 2022/09/14 22:31:04 UTC
[solr-sandbox] branch crossdc-wip updated: Flush producer on close to prevent losing any pending updates. (#38)
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 <ma...@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();
}
}