You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2021/02/15 10:39:09 UTC

[camel-kafka-connector] 08/10: Removed incorrect log message about connector initialization

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 <op...@redhat.com>
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");