[camel-kafka-connector] 14/14: Use a immutable singleton list instead in the test KafkaClient

[or...@apache.org]

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

orpiske pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git

commit 75110dfe4981445fe488ab4bf25fb05be568e040
Author: Otavio Rodolfo Piske <op...@redhat.com>
AuthorDate: Wed Jan 13 15:33:25 2021 +0100

    Use a immutable singleton list instead in the test KafkaClient
---
 .../camel/kafkaconnector/common/clients/kafka/KafkaClient.java       | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/clients/kafka/KafkaClient.java b/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/clients/kafka/KafkaClient.java
index a124a5d..4830843 100644
--- a/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/clients/kafka/KafkaClient.java
+++ b/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/clients/kafka/KafkaClient.java
@@ -18,7 +18,6 @@
 package org.apache.camel.kafkaconnector.common.clients.kafka;
 
 import java.time.Duration;
-import java.util.Arrays;
 import java.util.Collections;
 import java.util.Map;
 import java.util.Properties;
@@ -90,7 +89,7 @@ public class KafkaClient<K, V> {
      * @param recordConsumer the a function to consume the received messages
      */
     public void consumeAvailable(String topic, Consumer<ConsumerRecord<K, V>> recordConsumer) {
-        consumer.subscribe(Arrays.asList(topic));
+        consumer.subscribe(Collections.singletonList(topic));
 
         ConsumerRecords<K, V> records = consumer.poll(Duration.ofMillis(100));
         for (ConsumerRecord<K, V> record : records) {
@@ -106,7 +105,7 @@ public class KafkaClient<K, V> {
      * @param predicate the predicate to test when the messages arrive
      */
     public void consume(String topic, Predicate<ConsumerRecord<K, V>> predicate) {
-        consumer.subscribe(Arrays.asList(topic));
+        consumer.subscribe(Collections.singletonList(topic));
 
         // TODO: handle failures, timeouts, etc
         while (true) {