Removed incorrect log message about connector initialization
@@ -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");
