This is an automated email from the ASF dual-hosted git repository. orpiske pushed a commit to branch camel-master in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit ab56f43f1b743ba23c68eabedf618e180cc16019 Author: Otavio Rodolfo Piske <[email protected]> AuthorDate: Mon Feb 15 10:35:45 2021 +0100 Removed incorrect log message about connector initialization --- .../apache/camel/kafkaconnector/common/test/CamelSourceTestSupport.java | 2 -- 1 file changed, 2 deletions(-) diff --git a/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/test/CamelSourceTestSupport.java b/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/test/CamelSourceTestSupport.java index 7f8b03c..88f278d 100644 --- a/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/test/CamelSourceTestSupport.java +++ b/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/test/CamelSourceTestSupport.java @@ -70,7 +70,6 @@ public abstract class CamelSourceTestSupport extends AbstractKafkaTest { public void runTest(ConnectorPropertyFactory connectorPropertyFactory, TestMessageConsumer<?> consumer, FunctionalTestMessageProducer producer) throws ExecutionException, InterruptedException { connectorPropertyFactory.log(); - LOG.debug("Initialized the connector and put the data for the test execution"); getKafkaConnectService().initializeConnector(connectorPropertyFactory); LOG.debug("Producing test data to be collected by the connector and sent to Kafka"); @@ -107,7 +106,6 @@ public abstract class CamelSourceTestSupport extends AbstractKafkaTest { public void runTestBlocking(ConnectorPropertyFactory connectorPropertyFactory, TestMessageConsumer<?> consumer, FunctionalTestMessageProducer producer) throws ExecutionException, InterruptedException { connectorPropertyFactory.log(); - LOG.debug("Initialized the connector and put the data for the test execution"); getKafkaConnectService().initializeConnectorBlocking(connectorPropertyFactory, 1); LOG.debug("Producing test data to be collected by the connector and sent to Kafka");
