(flink-connector-kafka) 02/02: Fix compatibility with 2.1-SNAPSHOT.

[ar...@apache.org]

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

arvid pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-kafka.git

commit 11c226452900ca373f66e84c2e14aa94280a59ac
Author: lvyanquan <lv...@alibaba-inc.com>
AuthorDate: Tue Apr 1 19:50:31 2025 +0800

    Fix compatibility with 2.1-SNAPSHOT.
---
 .../java/org/apache/flink/connector/kafka/sink/KafkaSinkITCase.java | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaSinkITCase.java b/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaSinkITCase.java
index 0372d674..b2c182e1 100644
--- a/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaSinkITCase.java
+++ b/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaSinkITCase.java
@@ -66,8 +66,6 @@ import org.apache.flink.testutils.junit.SharedObjectsExtension;
 import org.apache.flink.testutils.junit.SharedReference;
 import org.apache.flink.util.TestLogger;
 
-import org.apache.flink.shaded.guava32.com.google.common.collect.Lists;
-
 import org.apache.kafka.clients.CommonClientConfigs;
 import org.apache.kafka.clients.admin.AdminClient;
 import org.apache.kafka.clients.admin.CreateTopicsResult;
@@ -551,7 +549,9 @@ public class KafkaSinkITCase extends TestLogger {
         public void notifyCheckpointComplete(long checkpointId) throws Exception {
             // sync with shared object, this is guaranteed to sync eventually because of final
             // checkpoint
-            checkpointedRecords.get().addAll(Lists.newArrayList(snapshottedRecords.get()));
+            ArrayList<Long> committedRecords = new ArrayList<>();
+            snapshottedRecords.get().forEach(committedRecords::add);
+            checkpointedRecords.get().addAll(committedRecords);
         }
 
         @Override