From 6e39fb7747cf027f1cf116dd559a3cf3b4d5614f Mon Sep 17 00:00:00 2001
From: jiangpengcheng <scjiangpengcheng@gmail.com>
Date: Thu, 9 Jan 2025 17:25:36 +0800
Subject: [PATCH] Use Time.SYSTEM for initializing system time

---
 .../io/aiven/connect/elasticsearch/ElasticsearchWriter.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/main/java/io/aiven/connect/elasticsearch/ElasticsearchWriter.java b/src/main/java/io/aiven/connect/elasticsearch/ElasticsearchWriter.java
index 7aba173..38eb6f1 100644
--- a/src/main/java/io/aiven/connect/elasticsearch/ElasticsearchWriter.java
+++ b/src/main/java/io/aiven/connect/elasticsearch/ElasticsearchWriter.java
@@ -26,7 +26,7 @@
 import java.util.Objects;
 import java.util.Set;
 
-import org.apache.kafka.common.utils.SystemTime;
+import org.apache.kafka.common.utils.Time;
 import org.apache.kafka.connect.errors.ConnectException;
 import org.apache.kafka.connect.sink.SinkRecord;
 
@@ -92,7 +92,7 @@ public class ElasticsearchWriter {
         this.behaviorOnMalformedDoc = behaviorOnMalformedDoc;
 
         bulkProcessor = new BulkProcessor<>(
-            new SystemTime(),
+            Time.SYSTEM,
             new BulkIndexingClient(client),
             maxBufferedRecords,
             maxInFlightRequests,