(flink-connector-kafka) branch main updated: [hotfix] Fix compiler varargs warning in KafkaSinkBuilderTest (#297)

[davidrad]

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

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


The following commit(s) were added to refs/heads/main by this push:
     new 1dbc33b3 [hotfix] Fix compiler varargs warning in KafkaSinkBuilderTest 
(#297)
1dbc33b3 is described below

commit 1dbc33b376760ef16246185651de3d2ebdb1a6c6
Author: Sylwester Lachiewicz <slachiew...@apache.org>
AuthorDate: Thu Sep 3 11:48:25 2026 +0200

    [hotfix] Fix compiler varargs warning in KafkaSinkBuilderTest (#297)
---
 .../connector/kafka/sink/KafkaSinkBuilderTest.java    | 19 ++++++-------------
 1 file changed, 6 insertions(+), 13 deletions(-)

diff --git 
a/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaSinkBuilderTest.java
 
b/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaSinkBuilderTest.java
index 9929d24a..2e4fec73 100644
--- 
a/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaSinkBuilderTest.java
+++ 
b/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaSinkBuilderTest.java
@@ -23,7 +23,6 @@ import org.apache.flink.connector.base.DeliveryGuarantee;
 import org.apache.kafka.clients.producer.ProducerConfig;
 import org.junit.jupiter.api.Test;
 
-import java.util.Arrays;
 import java.util.Properties;
 import java.util.function.Consumer;
 
@@ -33,8 +32,8 @@ import static 
org.assertj.core.api.Assertions.assertThatThrownBy;
 /** Tests for {@link KafkaSinkBuilder}. */
 class KafkaSinkBuilderTest {
 
-    private static final String[] DEFAULT_KEYS =
-            new String[] {
+    private static final Object[] DEFAULT_KEYS =
+            new Object[] {
                 ProducerConfig.BOOTSTRAP_SERVERS_CONFIG,
                 ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,
                 ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,
@@ -43,17 +42,11 @@ class KafkaSinkBuilderTest {
 
     @Test
     void testPropertyHandling() {
-        validateProducerConfig(
-                getBasicBuilder(),
-                p -> {
-                    Arrays.stream(DEFAULT_KEYS).forEach(k -> 
assertThat(p).containsKey(k));
-                });
+        validateProducerConfig(getBasicBuilder(), p -> 
assertThat(p).containsKeys(DEFAULT_KEYS));
 
         validateProducerConfig(
                 getBasicBuilder().setProperty("k1", "v1"),
-                p -> {
-                    Arrays.stream(DEFAULT_KEYS).forEach(k -> 
assertThat(p).containsKey(k));
-                });
+                p -> assertThat(p).containsKeys(DEFAULT_KEYS));
 
         Properties testConf = new Properties();
         testConf.put("k1", "v1");
@@ -62,7 +55,7 @@ class KafkaSinkBuilderTest {
         validateProducerConfig(
                 getBasicBuilder().setKafkaProducerConfig(testConf),
                 p -> {
-                    Arrays.stream(DEFAULT_KEYS).forEach(k -> 
assertThat(p).containsKey(k));
+                    assertThat(p).containsKeys(DEFAULT_KEYS);
                     testConf.forEach((k, v) -> 
assertThat(p.get(k)).isEqualTo(v));
                 });
 
@@ -72,7 +65,7 @@ class KafkaSinkBuilderTest {
                         .setKafkaProducerConfig(testConf)
                         .setProperty("k2", "correct"),
                 p -> {
-                    Arrays.stream(DEFAULT_KEYS).forEach(k -> 
assertThat(p).containsKey(k));
+                    assertThat(p).containsKeys(DEFAULT_KEYS);
                     assertThat(p).containsEntry("k1", 
"v1").containsEntry("k2", "correct");
                 });
     }