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 e52aba2c556d418e46d9af078a7dd5fe6c1183d3 Author: Otavio Rodolfo Piske <[email protected]> AuthorDate: Wed Jan 13 15:16:38 2021 +0100 Force the embedded runner to throw an exception if the provided service is null --- .../common/services/kafkaconnect/KafkaConnectRunnerService.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafkaconnect/KafkaConnectRunnerService.java b/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafkaconnect/KafkaConnectRunnerService.java index 8fadc26..c895490 100644 --- a/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafkaconnect/KafkaConnectRunnerService.java +++ b/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafkaconnect/KafkaConnectRunnerService.java @@ -41,7 +41,7 @@ public class KafkaConnectRunnerService implements KafkaConnectService { public KafkaConnectRunnerService(KafkaService kafkaService) { - Objects.nonNull(kafkaService); + Objects.requireNonNull(kafkaService); LOG.debug("Connecting the Kafka Connect Runner to {}", kafkaService.getBootstrapServers()); this.kafkaConnectRunner = new KafkaConnectRunner(kafkaService.getBootstrapServers());
