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 <[email protected]> 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) {
